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

Class CloseableTask<C extends java.io.Closeable>

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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      @NotNull de.dytanic.cloudnet.common.concurrent.ITask<C> addListener​(de.dytanic.cloudnet.common.concurrent.ITaskListener<C> listener)  
      C call()  
      boolean cancel​(boolean mayInterruptIfRunning)  
      @NotNull de.dytanic.cloudnet.common.concurrent.ITask<C> clearListeners()  
      void close()  
      C get()  
      C get​(long timeout, @NotNull java.util.concurrent.TimeUnit unit)  
      C get​(long time, java.util.concurrent.TimeUnit timeUnit, C def)  
      java.util.concurrent.Callable<C> getCallable()  
      C getDef​(C def)  
      java.util.Collection<de.dytanic.cloudnet.common.concurrent.ITaskListener<C>> getListeners()  
      boolean isCancelled()  
      boolean isDone()  
      <T> de.dytanic.cloudnet.common.concurrent.ITask<T> mapThrowable​(de.dytanic.cloudnet.common.concurrent.function.ThrowableFunction<C,​T,​java.lang.Throwable> mapper)  
      java.io.InputStream toInputStream()  
      java.io.OutputStream toOutputStream()  

      • 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, fireExceptionOnFailure, map, onCancelled, onComplete, onComplete, onFailure, onFailure

    • Method Detail

      • toOutputStream

        public java.io.OutputStream toOutputStream()

      • toInputStream

        public java.io.InputStream toInputStream()

      • close

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

      • addListener

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

      • clearListeners

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

      • getListeners

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

      • getCallable

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

      • getDef

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

      • get

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

      • mapThrowable

        public <T> de.dytanic.cloudnet.common.concurrent.ITask<T> mapThrowable​(de.dytanic.cloudnet.common.concurrent.function.ThrowableFunction<C,​T,​java.lang.Throwable> mapper)
        Specified by:
        mapThrowable in interface de.dytanic.cloudnet.common.concurrent.ITask<C extends java.io.Closeable>

      • call

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

      • cancel

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

      • isCancelled

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

      • isDone

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

      • get

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

      • get

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