sealed trait ManagedStreams[Key] extends TaskStreams[Key]
- Alphabetic
- By Inheritance
- ManagedStreams
- TaskStreams
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
binary(sid: String = default): BufferedOutputStream
Provides an output stream for writing to the stream with the given ID.
Provides an output stream for writing to the stream with the given ID.
- Definition Classes
- TaskStreams
-
abstract
def
cacheDirectory: File
A cache directory that is unique to the context of this streams instance.
A cache directory that is unique to the context of this streams instance.
- Definition Classes
- TaskStreams
-
abstract
def
cacheStoreFactory: CacheStoreFactory
- Definition Classes
- TaskStreams
- abstract def close(): Unit
-
abstract
def
getInput(key: Key, sid: String = default): Input
- Definition Classes
- TaskStreams
-
abstract
def
getOutput(sid: String = default): Output
- Definition Classes
- TaskStreams
- abstract def isClosed: Boolean
-
abstract
def
key: Key
- Definition Classes
- TaskStreams
-
abstract
def
log(sid: String): ManagedLogger
Creates a Logger that logs to stream with ID
sid.Creates a Logger that logs to stream with ID
sid.- Definition Classes
- TaskStreams
- abstract def open(): Unit
-
abstract
def
readBinary(a: Key, sid: String = default): BufferedInputStream
Provides an output stream to read from the stream
sidforkey.Provides an output stream to read from the stream
sidforkey. It is the caller's responsibility to coordinate writing to the stream. That is, no synchronization or ordering is provided and so this method should only be called when writing is complete.- Definition Classes
- TaskStreams
-
abstract
def
readText(key: Key, sid: String = default): BufferedReader
Provides a reader to read text from the stream
sidforkey.Provides a reader to read text from the stream
sidforkey. It is the caller's responsibility to coordinate writing to the stream. That is, no synchronization or ordering is provided and so this method should only be called when writing is complete.- Definition Classes
- TaskStreams
-
abstract
def
text(sid: String = default): PrintWriter
Provides a writer for writing text to the stream with the given ID.
Provides a writer for writing text to the stream with the given ID.
- Definition Classes
- TaskStreams
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
default: String
The default stream ID, used when an ID is not provided.
The default stream ID, used when an ID is not provided.
- Definition Classes
- TaskStreams
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
errorID: String
- Definition Classes
- TaskStreams
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
lazy val
log: ManagedLogger
Obtains the default logger.
Obtains the default logger.
- Definition Classes
- TaskStreams
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
outID: String
- Definition Classes
- TaskStreams
-
final
def
readBinary(a: Key, sid: Option[String]): BufferedInputStream
- Definition Classes
- TaskStreams
-
final
def
readText(a: Key, sid: Option[String]): BufferedReader
- Definition Classes
- TaskStreams
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()