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
sid
forkey
.Provides an output stream to read from the stream
sid
forkey
. 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
sid
forkey
.Provides a reader to read text from the stream
sid
forkey
. 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()