package com.pubnub.api;

import java.util.concurrent.TimeUnit;

import static com.jayway.awaitility.Awaitility.await;

import static org.hamcrest.Matchers.equalTo;

import static org.hamcrest.Matchers.notNullValue;

import static org.junit.Assert.assertThat;

import org.junit.Test;

import com.pubnub.api.Callback;

import com.pubnub.api.Pubnub;

import com.pubnub.api.PubnubError;

class PublishResult {

int result = 0;

}

public class Subscribe {

@Test

public void shouldReceiveMessage() throws Exception {

Pubnub pubnub = new Pubnub("demo", "demo");

PublishResult pr = new PublishResult();

pubnub.publish("demo", "demo", new Callback() {

public void successCallback(String channel, Object message) {

System.out.println(message);

// pr.result = 1;

}

public void errorCallback(String channel, PubnubError error) {

}

});

await().pollDelay(1, TimeUnit.MICROSECONDS).until(() -> pr.result == 1);

}

}