import com.pusher.client.Pusher; //导入依赖的package包/类
public PusherClient(String key) {

        channels = new HashMap<>();

        PusherOptions options = new PusherOptions();
        pusher = new Pusher(key, options);
        pusher.connect(new ConnectionEventListener() {
            @Override
            public void onConnectionStateChange(ConnectionStateChange change) {
                log("State changed from " + change.getPreviousState() + " to " + change.getCurrentState());
            }

            @Override
            public void onError(String message, String code, Exception e) {
                log("Error: " + message + " (" + code + ")");
            }
        }, ConnectionState.ALL);

    }
 

import com.pusher.client.Pusher; //导入依赖的package包/类
@Test
public void testInitializeNotificationService_Success() throws Exception {
    PusherOptions mockPusherOptions = PowerMockito.mock(PusherOptions.class);
    Pusher mockPusher               = PowerMockito.mock(Pusher.class);
    Channel mockChannel             = Mockito.mock(Channel.class);

    PowerMockito.whenNew(PusherOptions.class).withNoArguments().thenReturn(mockPusherOptions);
    Mockito.when(mockPusherOptions.setCluster(Mockito.anyString())).thenReturn(mockPusherOptions);
    Mockito.when(mockPusherOptions.setActivityTimeout(Mockito.anyLong())).thenReturn(mockPusherOptions);
    PowerMockito.whenNew(Pusher.class).withArguments(Mockito.anyString(), Mockito.isA(PusherOptions.class)).thenReturn(mockPusher);
    Mockito.doNothing().when(mockPusher).connect(Mockito.isA(ConnectionEventListener.class), Mockito.isA(ConnectionState.class));
    Mockito.when(mockPusher.subscribe(Mockito.anyString())).thenReturn(mockChannel);
    Mockito.doNothing().when(mockChannel).bind(Mockito.anyString(), Mockito.isA(SubscriptionEventListener.class));

    boolean result = pusherNotificationService.initializeNotificationService(getPlatformAuthDetailsResponseVO);
    assertThat(result).isTrue();

    PowerMockito.verifyNew(PusherOptions.class).withNoArguments();
    Mockito.verify(mockPusherOptions, Mockito.times(1)).setCluster(Mockito.anyString());
    Mockito.verify(mockPusherOptions, Mockito.times(1)).setActivityTimeout(Mockito.anyLong());
    PowerMockito.verifyNew(Pusher.class).withArguments(Mockito.anyString(), Mockito.isA(PusherOptions.class));
    Mockito.verify(mockPusher).connect(Mockito.isA(ConnectionEventListener.class), Mockito.isA(ConnectionState.class));
    Mockito.verify(mockPusher, Mockito.times(1)).subscribe(Mockito.anyString());
    Mockito.verify(mockChannel, Mockito.atLeastOnce()).bind(Mockito.anyString(), Mockito.isA(SubscriptionEventListener.class));
}
 

import com.pusher.client.Pusher; //导入依赖的package包/类
private void subscribe() {
    String apiKey = "cb65d0a7a72cd94adf1f";

    PusherOptions options = new PusherOptions().setEncrypted(true);
    Pusher pusher = new Pusher(apiKey, options);
    pusher.connect(this);

    // Subscribe to tickers
    pusher.subscribe("ticker.3", this, eventName);   // LTC / BTC
    pusher.subscribe("ticker.132", this, eventName); // DOGE / BTC
    pusher.subscribe("ticker.155", this, eventName); // DRK / BTC

    // Keep main thread asleep while we watch for events or application will terminate
    while (!stop) {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}
 

import com.pusher.client.Pusher; //导入依赖的package包/类
private PusherAndroid(final String appKey,
                      final PusherAndroidOptions pusherOptions, final PusherAndroidFactory factory) {
    this.pusher = new Pusher(appKey, pusherOptions);
    this.pushNotificationRegistration =
            new PushNotificationRegistration(appKey, pusherOptions, factory, new ManifestValidator());

}
 

import com.pusher.client.Pusher; //导入依赖的package包/类
/**
 * Create the {@link com.pusher.client.Pusher} instances.
 */
public Pusher build() {
    if (options == null) {
        return new Pusher(API_KEY);
    }
    return new Pusher(API_KEY, options);
}
 

import com.pusher.client.Pusher; //导入依赖的package包/类
IdobataStreamImpl(Idobata idobata, Pusher pusher, String channelName, Converter converter) {
    this.idobata = idobata;
    this.pusher = pusher;
    this.channelName = channelName;
    this.converter = converter;
    presenceChannel = pusher.subscribePresence(channelName);
}
 

import com.pusher.client.Pusher; //导入依赖的package包/类
@Override
public Pusher build() {
    return pusher;
}
 

import com.pusher.client.Pusher; //导入依赖的package包/类
public PusherBinder(Client client, String key, String region)
{
    PusherOptions options = new PusherOptions();

    options.setCluster(region);

    Pusher pusher = new Pusher(key, options);

    pusher.connect();

    channel = pusher.subscribe(client.getGame());
}