@Test public void testHandleResponse() { Action0 onSuccessMock = mock(Action0.class); Action0 onFailMock = mock(Action0.class); OpenSession openSession = OpenSession.newSession(() -> "*16*REQUEST"); openSession.addAllResponse(Lists.newArrayList(() -> OpenMessage.ACK)); Observable.just(openSession) .map(handleResponse(onSuccessMock, onFailMock)) .subscribe(); verify(onSuccessMock).call(); verify(onFailMock, never()).call(); }
public static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail) { return handleResponse(onSuccess, onFail, WHO_16); }
SoundSystem extends BaseOpenMessage { public static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail) { return handleResponse(onSuccess, onFail, WHO_16); } }
SoundSystem extends BaseOpenMessage { public static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail) { return handleResponse(onSuccess, onFail, WHO_16); } protected  SoundSystem(String value); }
SoundSystem extends BaseOpenMessage { public static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail) { return handleResponse(onSuccess, onFail, WHO_16); } protected  SoundSystem(String value); static SoundSystem requestTurnOn(String where, Type type, Source source); static SoundSystem requestTurnOff(String where, Type type, Source source); static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail); static SoundSystem requestStatus(String where, Type type); static Func1<OpenSession, OpenSession> handleStatus(Action0 onStatus, Action0 offStatus); static SoundSystem requestVolumeUp(String where, Type type); static SoundSystem requestVolumeDown(String where, Type type); static SoundSystem requestStationUp(String where, Type type); static SoundSystem requestStationDown(String where, Type type); }
SoundSystem extends BaseOpenMessage { public static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail) { return handleResponse(onSuccess, onFail, WHO_16); } protected  SoundSystem(String value); static SoundSystem requestTurnOn(String where, Type type, Source source); static SoundSystem requestTurnOff(String where, Type type, Source source); static Func1<OpenSession, OpenSession> handleResponse(Action0 onSuccess, Action0 onFail); static SoundSystem requestStatus(String where, Type type); static Func1<OpenSession, OpenSession> handleStatus(Action0 onStatus, Action0 offStatus); static SoundSystem requestVolumeUp(String where, Type type); static SoundSystem requestVolumeDown(String where, Type type); static SoundSystem requestStationUp(String where, Type type); static SoundSystem requestStationDown(String where, Type type);  }