@@ -23,20 +23,19 @@ BufferInt <- function(length=.Primitive("length"), append=.Primitive("c"),

 }

-setGeneric("BufferInterface", function(object) standardGeneric("BufferInterface"))

+setGeneric("BufferInterface",

+    function(object) standardGeneric("BufferInterface"))

 setMethod("BufferInterface", signature = signature(object = "ANY"),

-          function(object) {

-            BufferInt()

-          })

+    function(object) BufferInt())

 setMethod("BufferInterface", signature = signature(object = "data.frame"),

-          function(object) {

-            BufferInt(length=nrow, append=rbind, 

-                             subset=function(x, i){ 

-                                as.data.frame(sapply(x, .Primitive("["), i))

-                             })

-          })

+    function(object)

+{

+    BufferInt(length=nrow, append=rbind, subset=function(x, i) { 

+        as.data.frame(sapply(x, .Primitive("["), i))

+    })

+})

@@ -77,6 +77,15 @@

         if (verbose) msg("Consumer$.add()")

         .self$.records <- .self$.bufferInt$append(.records, input)

         .self    

+    },

+    show = function() 

+    {

+        callSuper()

+        inp <- rev(inputs())

+        indx <- !inp %in%"TOut" 

+        inp <- paste(inp[indx], collapse=" => ")

+        txt <- sprintf("stream: %s", inp)

+        cat(strwrap(txt, exdent=2), sep="\n")

     })

 setMethod(stream, "Consumer",

@@ -84,14 +93,3 @@ setMethod(stream, "Consumer",

 {

     .stream_set(x, ..., verbose=verbose)

 })

-

-setMethod(show, "Consumer",

-    function(object)

-{

-    callNextMethod()

-    inp <- rev(object$inputs())

-    indx = !inp %in%"TOut" 

-    inp <- paste(inp[indx], collapse=" => ")

-    txt <- sprintf("stream: %s", inp)

-    cat(strwrap(txt, exdent=2), sep="\n")

-})

@@ -45,21 +45,18 @@

         "report status of 'Downsample'"

         if (verbose) msg("Downsample$status()")

         c(list(probability=probability), callSuper())

+    },

+    show = function()

+    {

+        callSuper()

+        txt <- sprintf("probability: %.2f; yieldSize: %d",

+                       probability, yieldSize)

+        cat(txt, "\n")

     }))

 Downsample <-

-    function(probability = 0.1, ..., yieldSize = 1e6,

-             verbose=FALSE)

+    function(probability = 0.1, ..., yieldSize = 1e6, verbose=FALSE)

 {

     .Downsample$new(probability=probability, ...,

                     yieldSize=yieldSize, verbose=verbose)

 }

-    

-setMethod(show, "Downsample",

-    function(object)

-{

-    callNextMethod()

-    txt <- sprintf("probability: %.2f; yieldSize: %d",

-                   object$probability, object$yieldSize)

-    cat(txt, "\n")

-})

@@ -111,6 +111,15 @@ rawParserFactory <-

                .recordLength = length(.records),

                .bufferLength = length(.buffer)),

           callSuper())

+    },

+    show = function()

+    {

+        callSuper()

+        cat("file:", basename(summary(con)$description), "\n")

+        s <- status()

+        elts <- paste(names(s), s, sep="=", collapse=" ")

+        txt <- sprintf("status: %s", elts)

+        cat(strwrap(txt, exdent=2), sep="\n")

     })

@@ -126,14 +135,3 @@ RawInput <-

          reader=reader, parser=parser, ...,

          yieldSize=yieldSize, verbose=verbose)

 }

-

-setMethod(show, "RawInput",

-    function(object)

-{

-    callNextMethod()

-    cat("file:", basename(summary(object$con)$description), "\n")

-    s <- object$status()

-    elts <- paste(names(s), s, sep="=", collapse=" ")

-    txt <- sprintf("status: %s", elts)

-    cat(strwrap(txt, exdent=2), sep="\n")

-})

@@ -35,6 +35,10 @@

         "report status of Steamer"

         if (verbose) msg("Streamer$status()")

         list(yieldSize=yieldSize, verbose=verbose, inUse=inUse)

+    },

+    show = function()

+    {

+        cat("class:", class(.self), "\n")

     })

 setMethod(reset, "Streamer", function(x, ...) x$reset())

@@ -42,9 +46,3 @@ setMethod(reset, "Streamer", function(x, ...) x$reset())

 setMethod(yield, "Streamer", function(x, ...) x$yield())

 setMethod(status,"Streamer", function(x, ...) x$status())

-

-setMethod(show, "Streamer",

-    function(object)

-{

-    cat("class:", class(object), "\n")

-})

@@ -21,18 +21,17 @@

                        k$yield()

                    })

         do.call(.self$.fun, args)

+    },

+    show = function()

+    {

+        callSuper()

+        upstream <- paste(lapply(.upstream, "class"), collapse = " ,")

+        upstream[!nzchar(upstream)] <- "uninitialized field"

+        txt <- sprintf("upstream: %s", upstream)

+        cat(strwrap(txt, exdent=2), sep="\n")

     })

 YConnector <- function(fun, ...,  yieldSize =1e6, verbose = FALSE) 

 {

     .YConnector$new(fun=fun, ..., yieldSize=yieldSize, verbose=verbose)

 }

-

-setMethod(show, "YConnector",

-    function(object)

-{

-    cat("class:", class(object), "\n")

-    upstream <- paste(lapply(object$.upstream, "class"), collapse = " ,")

-    txt <- sprintf("upstream: %s", if(upstream=="") "uninitialized field" else upstream)

-    cat(strwrap(txt, exdent=2), sep="\n")

-})