    @Test
    public void subscribeShoulCallUnderlyingClient() throws ConsumedThingException, ProtocolClientException {

        when(thing.getClientFor(any(List.class), any())).thenReturn(new Pair(client, form));
        when(client.writeResource(any(), any())).thenReturn(completedFuture(null));
        when(client.observeResource(any())).thenReturn(observable);

        ConsumedThingProperty<Object> consumedThingProperty = new ConsumedThingProperty<Object>("myProperty", property, thing);
        consumedThingProperty.observer().subscribe(observer);

        verify(client).observeResource(any());
    }