RoomApiTest.java 文件源码

@Test
public void sendMessage() throws IOException {
    server.setDispatcher(new Dispatcher() {
        @Override
        public MockResponse dispatch(RecordedRequest request) throws InterruptedException {
            final String body = request.getBody().readUtf8();
            receivedNotification = JacksonUtils.deserialize(body, Notification.class);
            return new MockResponse();
        }
    });
    server.start();

    final RoomApiHttp http = getRoomApi(server, (oauthId, oauthSecret) -> getValidOAuthToken());
    http.sendMessage("hello", null);
    assertThat(receivedNotification, is(new Notification("hello", null)));
}