@Test public void fiamAnalyticsConnectorListener_ok() throws Exception { FiamAnalyticsConnectorListener listener = new FiamAnalyticsConnectorListener(emitter); Bundle bundle = new Bundle(); String eventName = "event1"; bundle.putString("events", eventName); listener.onMessageTriggered( AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID, bundle); verify(emitter, times(1)).onNext(eventName); }
@Override public void onMessageTriggered(int id, Bundle extras) { if (id == AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID) { emitter.onNext(extras.getString("events")); } }
FiamAnalyticsConnectorListener implements AnalyticsConnectorListener { @Override public void onMessageTriggered(int id, Bundle extras) { if (id == AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID) { emitter.onNext(extras.getString("events")); } } }
FiamAnalyticsConnectorListener implements AnalyticsConnectorListener { @Override public void onMessageTriggered(int id, Bundle extras) { if (id == AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID) { emitter.onNext(extras.getString("events")); } } FiamAnalyticsConnectorListener(FlowableEmitter<String> emitter); }
FiamAnalyticsConnectorListener implements AnalyticsConnectorListener { @Override public void onMessageTriggered(int id, Bundle extras) { if (id == AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID) { emitter.onNext(extras.getString("events")); } } FiamAnalyticsConnectorListener(FlowableEmitter<String> emitter); @Override void onMessageTriggered(int id, Bundle extras); }
FiamAnalyticsConnectorListener implements AnalyticsConnectorListener { @Override public void onMessageTriggered(int id, Bundle extras) { if (id == AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID) { emitter.onNext(extras.getString("events")); } } FiamAnalyticsConnectorListener(FlowableEmitter<String> emitter); @Override void onMessageTriggered(int id, Bundle extras);  }