EventStoreTest.java

package io.txb.eventstore;

import static org.junit.Assert.assertTrue;

import org.junit.Test;

import rx.Observable;
import rx.Subscriber;
import rx.Subscription;

public class EventStoreTest {
  @Test
  public void testApp() {
    EventStore.Context ctx = new EventStore.Context().address("localhost", 1113);
    try (final EventStore store = EventStore.connect(ctx)) {
      Observable<Event> orders = store.stream("BTC/CAD");
      Subscription subscription = orders.subscribe();
      subscription.unsubscribe();
    }
    assertTrue(true);
  }
}