@Test
public void createConnection() throws Exception {

    when(rxTapglue.createConnection(connection)).thenReturn(Observable.just(connection));
    assertThat(tapglue.createConnection(connection), equalTo(connection));
}