@Override
        public Promise<Void> sendMessage(T message) {
            Objects.requireNonNull(message, "message");
            return Schedulers.async().call(() -> {
                byte[] buf = this.codec.encode(message);
                this.messenger.outgoingMessages.accept(this.name, buf);
                return null;
            });
        }
Distributes an oncoming message to the channels held in this messenger.

@param channel the channel the message was received on
@param message the message
helper/src/main/java/me/lucko/helper/messaging/AbstractMessenger.java