onCreate method

  1. @override
void onCreate()
override

Implementation

@override
void onCreate() {
  super.onCreate();
  if (_onCreated) {
    return;
  }
  _onCreated = true;
  messages?.listen((event) {
    TypedEvent<JanusEvent> typedEvent = TypedEvent<JanusEvent>(event: JanusEvent.fromJson(event.event), jsep: event.jsep);
    var data = typedEvent.event.plugindata?.data;
    if (data == null) return;
    if (data["streaming"] == "event" && data["result"] != null && data["result"]['status'] == 'preparing') {
      typedEvent.event.plugindata?.data = StreamingPluginPreparingEvent();
      _typedMessagesSink?.add(typedEvent);
    } else if (data["streaming"] == "event" && data["result"] != null && data["result"]['status'] == 'stopping') {
      typedEvent.event.plugindata?.data = StreamingPluginStoppingEvent();
      _typedMessagesSink?.add(typedEvent);
    } else if (data['streaming'] == 'event' && (data['error_code'] != null || data['result']?['code'] != null)) {
      _typedMessagesSink?.addError(JanusError.fromMap(data));
    }
  });
}