### Question:
CorePeripheralManager implements PeripheralManager { @Override public Observable<byte[]> notification(UUID characteristic) { return peripheralRelay.switchMap(peripheral -> peripheral.notification(characteristic)); }  @Override void setPeripheral(Peripheral peripheral); @Override Single<T> queueOperation(PeripheralOperation<T> peripheralOperation); @Override Observable<Boolean> connected(); @Override Observable<byte[]> notification(UUID characteristic);  }### Answer:
@Test public void noitifcation() { when(peripheral.notification(any())).thenReturn(notificationRelay.hide()); TestObserver<byte[]> notificationTestObserver = corePeripheralManager.notification(chrUuid).test(); byte[] notification = new byte[] {0x00}; notificationRelay.accept(notification); notificationTestObserver.assertValue(notification); }