final class Ops[S[_]] extends AnyRef
- Alphabetic
- By Inheritance
- Ops
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- type F[A] = Free[S, A]
- type G[E, A] = EitherT[F, E, A]
- type GE[A] = EitherT[F, FileSystemError, A]
- type M[A] = EitherT[Unsafe.FreeS, FileSystemError, A]
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
-
def
append(dst: AFile, src: Process[F, Data]): Process[M, FileSystemError]
Appends data to the given file, creating it if it doesn't exist.
Appends data to the given file, creating it if it doesn't exist. May not write all values from
srcin the presence of errors, will emit a FileSystemError for each input value that failed to write. -
def
appendChannel(dst: AFile): Channel[M, slamdata.Predef.Vector[Data], slamdata.Predef.Vector[FileSystemError]]
Returns a channel that appends chunks of data to the given file, creating it if it doesn't exist.
Returns a channel that appends chunks of data to the given file, creating it if it doesn't exist. Any errors encountered while writing are emitted, all attempts are made to continue consuming input until the source is exhausted.
-
def
appendChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]]): Process[M, FileSystemError]
Same as
appendbut accepts chunkedData. -
def
appendThese(dst: AFile, data: slamdata.Predef.Vector[Data]): M[slamdata.Predef.Vector[FileSystemError]]
Appends the given data to the specified file, creating it if it doesn't exist.
Appends the given data to the specified file, creating it if it doesn't exist. May not write every given value in the presence of errors, returns a FileSystemError for each input value that failed to write.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
create(dst: AFile, src: Process[F, Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]
Create the given file with the contents of
src.Create the given file with the contents of
src. Fails if already exists. -
def
createChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]
Same as
createbut accepts chunkedData. -
def
createThese(dst: AFile, data: slamdata.Predef.Vector[Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): M[slamdata.Predef.Vector[FileSystemError]]
Create the given file with the contents of
data.Create the given file with the contents of
data. Fails if already exists. May not write every given value in the presence of errors, returns a FileSystemError for each input value that failed to write. -
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.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
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
replace(dst: AFile, src: Process[F, Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]
Replace the contents of the given file with
src.Replace the contents of the given file with
src. Fails if the file doesn't exist. -
def
replaceChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]
Same as
replacebut accepts chunkedData. -
def
replaceWithThese(dst: AFile, data: slamdata.Predef.Vector[Data])(implicit QF: QueryFile.Ops[S], MF: ManageFile.Ops[S]): M[slamdata.Predef.Unit]
Replace the contents of the given file with
data.Replace the contents of the given file with
data. Fails if the file doesn't exist or if any errors were encountered during writing. -
def
save(dst: AFile, src: Process[F, Data])(implicit MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]
Write the data stream to the given path, replacing any existing contents, atomically.
Write the data stream to the given path, replacing any existing contents, atomically. Any errors during writing will abort the entire operation leaving any existing values unaffected.
-
def
saveChunked(dst: AFile, src: Process[F, slamdata.Predef.Vector[Data]])(implicit MF: ManageFile.Ops[S]): Process[M, slamdata.Predef.Unit]
Same as
savebut accepts chunkedData. -
def
saveThese(dst: AFile, data: slamdata.Predef.Vector[Data])(implicit MF: ManageFile.Ops[S]): M[slamdata.Predef.Unit]
Write the given data to the specified file, replacing any existing contents, atomically.
Write the given data to the specified file, replacing any existing contents, atomically. Any errors during writing will abort the entire operation leaving any existing values unaffected.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- implicit val unsafe: Unsafe[S]
-
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
- @native() @throws( ... )