SocketInternetObservingStrategy extends EndpointInternetObservingStrategy { @NonNull public static SocketInternetObservingStrategy create() { return builder().build(); } @VisibleForTesting  SocketInternetObservingStrategy(@NonNull Builder builder); @NonNull static SocketInternetObservingStrategy create(); @NonNull static Builder builder();  }
@Test public void shouldSubscribeCorrectly() { InternetObservingStrategy sut = SocketInternetObservingStrategy.create(); sut.observe().test().assertSubscribed(); }