}


    @Test
    public void test () throws IOException {
        runReadWriteTest(4096, 4 * 4096);
    }


    @Test
    public void testExactWrite () throws IOException {
        runReadWriteTest(4096, 4096);
    }


    @Test
    public void testSmallWrite () throws IOException {
        runReadWriteTest(4096, 1013);
    }


    @Test

     * available.
     *
     * @throws InterruptedException if the current thread was interrupted before or during the call
     *     (optional but recommended).
     * @throws CancellationException {@inheritDoc}
     */
    @CanIgnoreReturnValue
    @Override
    public V get(long timeout, TimeUnit unit)
        throws InterruptedException, TimeoutException, ExecutionException {
      return sync.get(unit.toNanos(timeout));
    }

   *
   * @throws NoSuchFileException if the file does not exist <i>(optional specific exception)</i>
   * @throws NotDirectoryException if the file could not be opened because it is not a directory
   *     <i>(optional specific exception)</i>
   * @throws IOException if an I/O error occurs
   */
  public static ImmutableList<Path> listFiles(Path dir) throws IOException {

   *
   * @throws NoSuchFileException if the file does not exist <i>(optional specific exception)</i>
   * @throws NotDirectoryException if the file could not be opened because it is not a directory
   *     <i>(optional specific exception)</i>
   * @throws IOException if an I/O error occurs
   */
  public static ImmutableList<Path> listFiles(Path dir) throws IOException {

        } else {
            throw new ResourceDoesNotExistException("No content provided for " + resource.getName());
        }
    }

    @Override
    public void fillOutputData(OutputData outputData) throws TransferFailedException {
        outputData.setOutputStream(new ByteArrayOutputStream());
    }

    @Override
    protected void openConnectionInternal() throws ConnectionException, AuthenticationException {}

java.util.Properties, Appendable); private java.net.URI prepareDistributionU() throws java.net.URISyntaxException; private java.net.URI readDistroUrl() throws java.net.URISyntaxException; private static void loadProperties(java.io.File, java.util.Properties) throws java.io.IOException; public java.net.URI getDistribution(); public WrapperConfiguration getConfiguration(); public void execute(String[], Installer, BootstrapMainStarter) throws Exception; private String getProperty(String); private String getProperty(String,...

        }
        else if ( usage < 0 ) {
            throw new RuntimeCIFSException("Usage count dropped below zero");
        }
    }


    /**
     * @return the sessionKey
     * @throws CIFSException
     */
    @Override
    public byte[] getSessionKey () throws CIFSException {
        if ( this.sessionKey == null ) {
            throw new CIFSException("No session key available");
        }

            super(invoker, invokerRequest);
        }

        @Override
        public void close() throws InvokerException {
            // we are resident, we do not shut down here
        }

        public void shutDown() throws InvokerException {
            super.close();
        }

        public LocalContext copy(MavenInvokerRequest<MavenOptions> invokerRequest) {

  }

  public void testCopyTo_appendable() throws IOException {
    StringBuilder builder = new StringBuilder();

    assertEquals(STRING.length(), source.copyTo(builder));
    assertTrue(source.wasStreamOpened() && source.wasStreamClosed());

    assertEquals(STRING, builder.toString());
  }

  public void testCopyTo_charSink() throws IOException {
    TestCharSink sink = new TestCharSink();

    public TemporaryFileInputStream(final File tempFile) throws FileNotFoundException {
        this.tempFile = tempFile;
        fileInputStream = new FileInputStream(tempFile);
    }

    public File getTemporaryFile() {
        return tempFile;
    }

    /*
     * (non-Javadoc)
     *
     * @see java.io.InputStream#read()
     */
    @Override
    public int read() throws IOException {
        return fileInputStream.read();