tee-stream

Vocabulary

io.streams.tee

Definition

IN: io.streams.tee

TUPLE: tee-stream in out ;

Methods

USING: destructors io.streams.tee io.streams.tee.private kernel
;

M: tee-stream dispose >tee-stream< [ dispose ] bi@ ;


USING: io io.streams.tee io.streams.tee.private ;

M: tee-stream stream-contents*
    [ stream-contents* ] [ stream-write ] tee1 ;


USING: accessors io io.streams.tee ;

M: tee-stream stream-element-type in>> stream-element-type ;


USING: io io.streams.tee io.streams.tee.private kernel math
sequences ;

M:: tee-stream stream-read-partial-unsafe
    ( n buf stream -- count )
    n buf stream
    [ stream-read-partial-unsafe ] [
        [ [ buf swap head ] ] dip [ stream-write ] curry compose
        unless-zero
    ] tee1 ;


USING: io io.streams.tee io.streams.tee.private kernel math
sequences ;

M:: tee-stream stream-read-unsafe ( n buf stream -- count )
    n buf stream
    [ stream-read-unsafe ] [
        [ [ buf swap head ] ] dip [ stream-write ] curry compose
        unless-zero
    ] tee1 ;


USING: io io.streams.tee io.streams.tee.private kernel ;

M: tee-stream stream-read-until
    >tee-stream<
    [ stream-read-until ] [
        dup [ [ stream-write ] curry [ when* ] curry ] dip
        [ stream-write1 ] curry [ when* ] curry [ bi* ] 2curry
        2over [ call ] 2dip
    ] bi* ;


USING: io io.streams.tee io.streams.tee.private ;

M: tee-stream stream-read1
    [ stream-read1 ] [ stream-write1 ] tee1 ;


USING: io io.streams.tee io.streams.tee.private kernel ;

M: tee-stream stream-readln
    [ stream-readln ]
    [ [ [ stream-write ] [ stream-nl ] bi ] curry when* ] tee1 ;