Home
last modified time | relevance | path

Searched refs:decoder (Results 1 – 4 of 4) sorted by relevance

/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java70 decoder.init(config); in PojoMessageHandlerWholeBinary()
71 decoders.add(decoder); in PojoMessageHandlerWholeBinary()
74 BinaryStream<?> decoder = (BinaryStream<?>) in PojoMessageHandlerWholeBinary() local
76 decoder.init(config); in PojoMessageHandlerWholeBinary()
77 decoders.add(decoder); in PojoMessageHandlerWholeBinary()
92 for (Decoder decoder : decoders) { in decode()
93 if (decoder instanceof Binary) { in decode()
94 if (((Binary<?>) decoder).willDecode(message)) { in decode()
95 return ((Binary<?>) decoder).decode(message); in decode()
127 for (Decoder decoder : decoders) { in onClose()
[all …]
H A DPojoMessageHandlerWholeText.java79 decoder.init(config); in PojoMessageHandlerWholeText()
80 decoders.add(decoder); in PojoMessageHandlerWholeText()
83 TextStream<?> decoder = in PojoMessageHandlerWholeText() local
85 decoder.init(config); in PojoMessageHandlerWholeText()
86 decoders.add(decoder); in PojoMessageHandlerWholeText()
105 for (Decoder decoder : decoders) { in decode()
106 if (decoder instanceof Text) { in decode()
107 if (((Text<?>) decoder).willDecode(message)) { in decode()
108 return ((Text<?>) decoder).decode(message); in decode()
132 for (Decoder decoder : decoders) { in onClose()
[all …]
H A DLocalStrings.properties28 pojoMethodMapping.invalidDecoder=The specified decoder of type [{0}] could not be instantiated
/unit/src/java/nginx/unit/websocket/
H A DUtil.java175 private static Class<?> getDecoderType(Class<? extends Decoder> decoder) { in getDecoderType() argument
176 return Util.getGenericType(Decoder.class, decoder).getClazz(); in getDecoderType()