Home
last modified time | relevance | path

Searched refs:Whole (Results 1 – 7 of 7) sorted by path

/unit/src/java/javax/websocket/
H A DMessageHandler.java33 interface Whole<T> extends MessageHandler { interface
H A DSession.java191 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Whole<T> handler) in addMessageHandler()
/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties111 wsSession.invalidHandlerTypePong=A pong message handler must implement MessageHandler.Whole
H A DUtil.java388 boolean whole = MessageHandler.Whole.class.isAssignableFrom(listener.getClass()); in getMessageHandlers()
H A DWsFrameBase.java352 MessageHandler.Whole<PongMessage> mhPong = wsSession.getPongMessageHandler(); in processDataControl()
393 ((MessageHandler.Whole<String>) textMsgHandler) in sendMessageText()
581 ((MessageHandler.Whole<ByteBuffer>) binaryMsgHandler).onMessage(msg); in sendMessageBinary()
H A DWsSession.java47 import javax.websocket.MessageHandler.Whole;
104 private volatile MessageHandler.Whole<PongMessage> pongMessageHandler = null;
245 public <T> void addMessageHandler(Class<T> clazz, Whole<T> handler) in addMessageHandler()
290 if (handler instanceof MessageHandler.Whole<?>) { in doAddMessageHandler()
291 pongMessageHandler = (MessageHandler.Whole<PongMessage>) handler; in doAddMessageHandler()
966 ((MessageHandler.Whole<String>) textMessageHandler).onMessage(text); in onMessage()
979 ((MessageHandler.Whole<ByteBuffer>) binaryMessageHandler).onMessage(buf); in onMessage()
1000 … ((MessageHandler.Whole<ByteBuffer>) binaryMessageHandler).onMessage(binaryBuffer); in onMessage()
1028 protected MessageHandler.Whole<PongMessage> getPongMessageHandler() { in getPongMessageHandler()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBase.java35 extends PojoMessageHandlerBase<T> implements MessageHandler.Whole<T> {