Package de.dytanic.cloudnet.ext.storage.ftp.storage.queue

Class OutputStreamCloseTask

  • All Implemented Interfaces:
    de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>, java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, java.util.concurrent.Callable<java.io.OutputStream>, java.util.concurrent.Future<java.io.OutputStream>
    @NotNull
public class OutputStreamCloseTask
extends java.io.OutputStream
implements de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      @NotNull de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream> addListener​(de.dytanic.cloudnet.common.concurrent.ITaskListener<java.io.OutputStream> listener)  
      java.io.OutputStream call()  
      boolean cancel​(boolean mayInterruptIfRunning)  
      @NotNull de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream> clearListeners()  
      void close()  
      void flush()  
      java.io.OutputStream get()  
      java.io.OutputStream get​(long timeout, @NotNull java.util.concurrent.TimeUnit unit)  
      java.io.OutputStream get​(long time, java.util.concurrent.TimeUnit timeUnit, java.io.OutputStream def)  
      java.util.concurrent.Callable<java.io.OutputStream> getCallable()  
      java.io.OutputStream getDef​(java.io.OutputStream def)  
      java.util.Collection<de.dytanic.cloudnet.common.concurrent.ITaskListener<java.io.OutputStream>> getListeners()  
      boolean isCancelled()  
      boolean isDone()  
      void write​(@org.jetbrains.annotations.NotNull byte[] b)  
      void write​(@org.jetbrains.annotations.NotNull byte[] b, int off, int len)  
      void write​(int b)  

      • Methods inherited from class java.io.OutputStream

        nullOutputStream

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

      • Methods inherited from interface de.dytanic.cloudnet.common.concurrent.ITask

        addListener, onCancelled, onComplete, onComplete, onFailure, onFailure

    • Method Detail

      • write

        public void write​(int b)
           throws java.io.IOException
        Specified by:
        write in class java.io.OutputStream
        Throws:
        java.io.IOException

      • write

        public void write​(@NotNull
                  @org.jetbrains.annotations.NotNull byte[] b)
           throws java.io.IOException
        Overrides:
        write in class java.io.OutputStream
        Throws:
        java.io.IOException

      • write

        public void write​(@NotNull
                  @org.jetbrains.annotations.NotNull byte[] b,
                  int off,
                  int len)
           throws java.io.IOException
        Overrides:
        write in class java.io.OutputStream
        Throws:
        java.io.IOException

      • flush

        public void flush()
           throws java.io.IOException
        Specified by:
        flush in interface java.io.Flushable
        Overrides:
        flush in class java.io.OutputStream
        Throws:
        java.io.IOException

      • close

        public void close()
           throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Overrides:
        close in class java.io.OutputStream
        Throws:
        java.io.IOException

      • addListener

        @NotNull
public @NotNull de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream> addListener​(de.dytanic.cloudnet.common.concurrent.ITaskListener<java.io.OutputStream> listener)
        Specified by:
        addListener in interface de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

      • clearListeners

        @NotNull
public @NotNull de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream> clearListeners()
        Specified by:
        clearListeners in interface de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

      • getListeners

        public java.util.Collection<de.dytanic.cloudnet.common.concurrent.ITaskListener<java.io.OutputStream>> getListeners()
        Specified by:
        getListeners in interface de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

      • getCallable

        public java.util.concurrent.Callable<java.io.OutputStream> getCallable()
        Specified by:
        getCallable in interface de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

      • getDef

        public java.io.OutputStream getDef​(java.io.OutputStream def)
        Specified by:
        getDef in interface de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

      • get

        public java.io.OutputStream get​(long time,
                                java.util.concurrent.TimeUnit timeUnit,
                                java.io.OutputStream def)
        Specified by:
        get in interface de.dytanic.cloudnet.common.concurrent.ITask<java.io.OutputStream>

      • call

        public java.io.OutputStream call()
        Specified by:
        call in interface java.util.concurrent.Callable<java.io.OutputStream>

      • cancel

        public boolean cancel​(boolean mayInterruptIfRunning)
        Specified by:
        cancel in interface java.util.concurrent.Future<java.io.OutputStream>

      • isCancelled

        public boolean isCancelled()
        Specified by:
        isCancelled in interface java.util.concurrent.Future<java.io.OutputStream>

      • isDone

        public boolean isDone()
        Specified by:
        isDone in interface java.util.concurrent.Future<java.io.OutputStream>

      • get

        public java.io.OutputStream get()
        Specified by:
        get in interface java.util.concurrent.Future<java.io.OutputStream>

      • get

        public java.io.OutputStream get​(long timeout,
                                @NotNull
                                @NotNull java.util.concurrent.TimeUnit unit)
        Specified by:
        get in interface java.util.concurrent.Future<java.io.OutputStream>