push method

void push(Message message)

Implementation

void push(Message message) {
  void callback() {
    encode(message.toJson(), (result) {
      // print('send message $result');
      conn?.sink.add(result);
    });
  }

  log(
    'push',
    '${message.topic} ${message.event} (${message.ref})',
    message.payload,
  );

  if (isConnected()) {
    callback();
  } else {
    sendBuffer.add(callback);
  }
}