Nothing
# :tabSize=4:indentSize=4:noTabs=false:folding=explicit:collapseFolds=1:
# {{{ generics
setGeneric( "flush" )
setGeneric( "close" )
setGeneric( "GetErrno", function(object){
standardGeneric( "GetErrno" )
} )
setGeneric( "SetCloseOnDelete", function(object, close=FALSE){
standardGeneric( "SetCloseOnDelete" )
} )
# }}}
# {{{ methods
setGeneric( "Next", function(object, payload){
standardGeneric( "Next" )
} )
setGeneric( "BackUp", function(object, count){
standardGeneric( "BackUp" )
} )
setGeneric( "ByteCount", function(object){
standardGeneric( "ByteCount" )
} )
setGeneric( "Skip", function(object, count){
standardGeneric( "Skip" )
} )
# }}}
# {{{ zero input stream
setMethod( "Next", c( object = "ZeroCopyInputStream", payload = "missing"), function(object, payload){
.Call(ZeroCopyInputStream_Next, object@pointer)
} )
setMethod( "BackUp", "ZeroCopyInputStream", function(object, count){
invisible(.Call(ZeroCopyInputStream_BackUp, object@pointer, count))
} )
setMethod( "ByteCount", "ZeroCopyInputStream", function(object){
.Call(ZeroCopyInputStream_ByteCount, object@pointer)
} )
setMethod( "Skip", "ZeroCopyInputStream", function(object, count){
invisible( .Call(ZeroCopyInputStream_Skip, object@pointer, count) )
} )
# }}}
# {{{ zero copy output stream
setMethod( "Next", c( object = "ZeroCopyOutputStream", payload = "raw" ), function(object, payload){
.Call(ZeroCopyOutputStream_Next, object@pointer, payload)
} )
setMethod( "BackUp", "ZeroCopyOutputStream", function(object, count){
invisible( .Call(ZeroCopyOutputStream_BackUp, object@pointer, count) )
} )
setMethod( "ByteCount", "ZeroCopyOutputStream", function(object){
.Call(ZeroCopyOutputStream_ByteCount, object@pointer)
} )
# }}}
# {{{ ArrayInputStream
setGeneric( "ArrayInputStream", function(payload, block_size){
standardGeneric( "ArrayInputStream" )
} )
setMethod( "ArrayInputStream", c( payload = "raw", block_size = "missing" ) ,
function(payload, block_size){
.Call(ArrayInputStream__new, payload, -1L)
} )
setMethod( "ArrayInputStream", c( payload = "raw", block_size = "integer" ) ,
function(payload, block_size){
.Call(ArrayInputStream__new, payload, block_size)
} )
setMethod( "ArrayInputStream", c( payload = "raw", block_size = "numeric" ) ,
function(payload, block_size){
.Call(ArrayInputStream__new, payload, as.integer(block_size))
} )
# }}}
# {{{ ArrayOutputStream constructor function
setGeneric( "ArrayOutputStream", function(size, block_size){
standardGeneric( "ArrayOutputStream" )
} )
setMethod( "ArrayOutputStream", signature( size = "integer", block_size = "missing" ), function(size, block_size){
.Call(ArrayOutputStream__new, size, -1L)
} )
setMethod( "ArrayOutputStream", signature( size = "integer", block_size = "integer" ), function(size, block_size){
.Call(ArrayOutputStream__new, size, block_size)
} )
setMethod( "ArrayOutputStream", signature( size = "integer", block_size = "numeric" ), function(size, block_size){
.Call(ArrayOutputStream__new, size, as.integer(block_size) )
} )
setMethod( "ArrayOutputStream", signature( size = "numeric", block_size = "missing" ), function(size, block_size){
.Call(ArrayOutputStream__new, as.integer(size), -1L)
} )
setMethod( "ArrayOutputStream", signature( size = "numeric", block_size = "integer" ),function(size, block_size){
.Call(ArrayOutputStream__new, as.integer(size), block_size)
} )
setMethod( "ArrayOutputStream", signature( size = "numeric", block_size = "numeric" ), function(size, block_size){
.Call(ArrayOutputStream__new, as.integer(size), as.integer(block_size) )
} )
# }}}
# {{{ FileInputStream
setGeneric( "FileInputStream", function(filename, block_size = -1L, close.on.delete = FALSE ){
standardGeneric( "FileInputStream" )
} )
setMethod( "FileInputStream", signature( filename = "character", block_size = "integer", close.on.delete = "logical" ), function(filename, block_size = -1L, close.on.delete = FALSE){
full_filename <- file_path_as_absolute(filename)
.Call(FileInputStream_new, filename, block_size, close.on.delete)
} )
setMethod( "close", "FileInputStream", function(con, ...){
.Call(FileInputStream_Close, con@pointer)
} )
setMethod( "GetErrno", "FileInputStream", function(object){
.Call(FileInputStream_GetErrno, object@pointer)
} )
setMethod( "SetCloseOnDelete", "FileInputStream", function(object, close=FALSE){
invisible( .Call(FileInputStream_SetCloseOnDelete, object@pointer, isTRUE(close)) )
} )
# }}}
# {{{ FileOutputStream
setGeneric( "FileOutputStream", function(filename, block_size = -1L, close.on.delete = FALSE ){
standardGeneric( "FileOutputStream" )
} )
setMethod( "FileOutputStream", signature( filename = "character", block_size = "integer", close.on.delete = "logical" ), function(filename, block_size = -1L, close.on.delete = FALSE){
if( !file.exists( filename ) ){
if( !file.exists( dirname(filename) ) ){
stop( "directory does not exist" )
}
filename <- normalizePath(filename, mustWork=FALSE)
} else{
filename <- file_path_as_absolute(filename)
}
.Call(FileOutputStream_new, filename, block_size, close.on.delete)
} )
setMethod( "flush", "FileOutputStream", function(con){
.Call(FileOutputStream_Flush, con@pointer)
} )
setMethod( "close", "FileOutputStream", function(con, ...){
.Call(FileOutputStream_Close, con@pointer)
} )
setMethod( "GetErrno", "FileOutputStream", function(object){
.Call(FileOutputStream_GetErrno, object@pointer)
} )
setMethod( "SetCloseOnDelete", "FileOutputStream", function(object, close=FALSE){
invisible( .Call(FileOutputStream_SetCloseOnDelete, object@pointer, isTRUE(close)) )
} )
# }}}
# {{{ ConnectionInputStream
setGeneric( "ConnectionInputStream", function(object, ...){
standardGeneric( "ConnectionInputStream" )
} )
setMethod( "ConnectionInputStream", "connection", function(object, ...){
sc <- summary( object )
if( ! identical( sc[["can read"]], "yes") ){
stop( "cannot read from connection" )
}
if( ! identical( sc[["text"]], "binary" ) ){
stop( "not a binary connection" )
}
was_open <- isOpen( object )
if( ! was_open ){
open( object )
}
.Call(ConnectionInputStream_new, object, was_open)
} )
# }}}
# {{{ ConnectionOutputStream
setGeneric( "ConnectionOutputStream", function(object, ...){
standardGeneric( "ConnectionOutputStream" )
} )
setMethod( "ConnectionOutputStream", "connection", function(object, ...){
sc <- summary( object )
if( ! identical( sc[["can write"]], "yes") ){
stop( "cannot write to connection" )
}
if( ! identical( sc[["text"]], "binary" ) ){
stop( "not a binary connection" )
}
was_open <- isOpen( object )
if( ! was_open ){
open( object )
}
.Call(ConnectionOutputStream_new, object, was_open)
} )
# }}}
Any scripts or data that you put into this service are public.
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.