import jcifs.internal.smb2.ioctl.SrvPipePeekResponse;

/**
 * Input stream for reading from SMB named pipes.
 *
 * This class provides a stream-based interface for reading
 * data from SMB named pipes over the network.
 *
 * @author mbechler
 */
public class SmbPipeInputStream extends SmbFileInputStream {

    private final SmbPipeHandleImpl handle;

    /**
     * @param handle
     * @param th

@Ignore("test runners must not instantiate and run this directly, only via suites we build")
// @Ignore affects the Android test runner, which respects JUnit 4 annotations on JUnit 3 tests.
@SuppressWarnings("JUnit4ClassUsedInJUnit3")
public class MultisetCountTester<E> extends AbstractMultisetTester<E> {

  public void testCount_0() {
    assertEquals("multiset.count(missing) didn't return 0", 0, getMultiset().count(e3()));
  }

import gradlebuild.docs.dsl.source.model.TypeMetaData;
import org.w3c.dom.Element;

import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

public class ClassDocMethodsBuilder extends ModelBuilderSupport {
    private final JavadocConverter javadocConverter;
    private final GenerationListener listener;

        lenient().doCallRealMethod().when(handle).doSendReceiveFragment(any(byte[].class), anyInt(), anyInt(), any(byte[].class));
        lenient().doCallRealMethod().when(handle).doSendFragment(any(byte[].class), anyInt(), anyInt());
        lenient().doCallRealMethod().when(handle).doReceiveFragment(any(byte[].class));
        lenient().doCallRealMethod().when(handle).close();

        assertThat(traverser.isExistClass(TestCase.class.getName()), is(not(true)));

        final Set<String> set = new HashSet<String>();
        traverser.forEach((ClassHandler) (packageName, shortClassName) -> set.add(ClassUtil.concatName(packageName, shortClassName)));
        assertThat(set.size() > 0, is(true));
        assertThat(set.contains(DummyTest.class.getName()), is(true));

### Consistency Guarantees

 * helper implementations to exercise expected interaction patterns and edge cases.
 */
@ExtendWith(MockitoExtension.class)
public class SmbRenewableCredentialsTest {

    // Simple base class to satisfy the extended CredentialsInternal contract
    static abstract class BaseCreds implements SmbRenewableCredentials {
        @Override
        public CredentialsInternal clone() {

import jcifs.CIFSContext;
import jcifs.Configuration;
import jcifs.internal.witness.WitnessRegistration.WitnessRegistrationState;

/**
 * Unit tests for WitnessClient class using mocks.
 */
@ExtendWith(MockitoExtension.class)
public class WitnessClientTest {

    @Mock
    private CIFSContext mockContext;

    @Mock
    private Configuration mockConfig;

    @Mock
    private WitnessRpcClient mockRpcClient;

    ImmutableList.Builder<String> builder = ImmutableList.builder();
    assertThrows(NullPointerException.class, () -> builder.add((String) null));

    assertThrows(NullPointerException.class, () -> builder.add((String[]) null));

    assertThrows(NullPointerException.class, () -> builder.add("a", null, "b"));
  }

  public void testBuilderAddAllHandlesNullsCorrectly() {
    {

    void copyFile_serverSide_zeroLength_happyPath() throws Exception {
        // Arrange
        SmbFile src = mock(SmbFile.class);
        SmbFile dest = mock(SmbFile.class);

        SmbTreeHandleImpl sh = mock(SmbTreeHandleImpl.class);
        SmbTreeHandleImpl dh = mock(SmbTreeHandleImpl.class);
        when(sh.isSMB2()).thenReturn(true);
        when(dh.isSMB2()).thenReturn(true);