import com.pusher.client.connection.ConnectionEventListener; //导入依赖的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.connection.ConnectionEventListener; //导入依赖的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.connection.ConnectionEventListener; //导入依赖的package包/类
@Override
public void connect(ConnectionEventListener eventListener, ConnectionState... connectionStates) {
    this.pusher.connect(eventListener, connectionStates);
}