@Test public void testSend() throws IOException { Message message = () -> null; packStream.send(message); verify(rpcSender).send(message); }
@Override public void send(Message message) throws IOException { log.debug("Sending message: {}", message); rpcSender.send(message); }
PackStream implements RpcStreamer { @Override public void send(Message message) throws IOException { log.debug("Sending message: {}", message); rpcSender.send(message); } }
PackStream implements RpcStreamer { @Override public void send(Message message) throws IOException { log.debug("Sending message: {}", message); rpcSender.send(message); } PackStream(RpcSender rpcSender, RpcListener rpcListener);  PackStream(RpcSender rpcSender, RpcListener rpcListener, MessageIdGenerator messageIdGenerator); }
PackStream implements RpcStreamer { @Override public void send(Message message) throws IOException { log.debug("Sending message: {}", message); rpcSender.send(message); } PackStream(RpcSender rpcSender, RpcListener rpcListener);  PackStream(RpcSender rpcSender, RpcListener rpcListener, MessageIdGenerator messageIdGenerator); @Override void attach(RpcConnection rpcConnection); @Override void send(Message message); @Override void send(RequestMessage.Builder requestMessage); @Override void send(RequestMessage.Builder requestMessage, RpcListener.ResponseCallback responseCallback); @Override void addRequestCallback(RpcListener.RequestCallback requestCallback); @Override void removeRequestCallback(RpcListener.RequestCallback requestCallback); @Override void addNotificationCallback(RpcListener.NotificationCallback notificationCallback); @Override void removeNotificationCallback(RpcListener.NotificationCallback notificationCallback); @Override void stop(); }
PackStream implements RpcStreamer { @Override public void send(Message message) throws IOException { log.debug("Sending message: {}", message); rpcSender.send(message); } PackStream(RpcSender rpcSender, RpcListener rpcListener);  PackStream(RpcSender rpcSender, RpcListener rpcListener, MessageIdGenerator messageIdGenerator); @Override void attach(RpcConnection rpcConnection); @Override void send(Message message); @Override void send(RequestMessage.Builder requestMessage); @Override void send(RequestMessage.Builder requestMessage, RpcListener.ResponseCallback responseCallback); @Override void addRequestCallback(RpcListener.RequestCallback requestCallback); @Override void removeRequestCallback(RpcListener.RequestCallback requestCallback); @Override void addNotificationCallback(RpcListener.NotificationCallback notificationCallback); @Override void removeNotificationCallback(RpcListener.NotificationCallback notificationCallback); @Override void stop(); static final Logger log; }