onCreate method
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));
}
});
}