steve
/
factor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

io.streams.sequence: faster stream-read-until.

db4
John Benediktsson 2012-07-11 18:26:41 -07:00
parent 09ea62edf6
commit a642f39a9a
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
core/io/streams/sequence/sequence.factor
View File

@ -23,23 +23,23 @@ SLOT: i
: <sequence-copy> ( dest n i src -- n copy ) : <sequence-copy> ( dest n i src -- n copy )
[ 0 ] 3curry dip <copy> ; inline [ 0 ] 3curry dip <copy> ; inline
: (sequence-read) ( n buf stream -- count ) : (sequence-read-unsafe) ( n buf stream -- count )
[ (sequence-read-length) ] [ (sequence-read-length) ]
[ [ dup pick + ] change-i underlying>> ] bi [ [ dup pick + ] change-i underlying>> ] bi
[ <sequence-copy> (copy) drop ] 2curry keep ; inline [ <sequence-copy> (copy) drop ] 2curry keep ; inline
: sequence-read-unsafe ( n buf stream -- count ) : sequence-read-unsafe ( n buf stream -- count )
dup >sequence-stream< bounds-check? dup >sequence-stream< bounds-check?
[ (sequence-read) ] [ 3drop 0 ] if ; inline [ (sequence-read-unsafe) ] [ 3drop 0 ] if ; inline
: find-sep ( seps stream -- sep/f n ) : find-separator ( seps stream -- sep/f n )
swap [ >sequence-stream< swap tail-slice ] dip swap [ >sequence-stream< ] dip
[ member-eq? ] curry [ find swap ] curry keep [ member-eq? ] curry [ find-from swap ] curry 2keep
over [ drop ] [ nip length ] if ; inline pick [ drop - ] [ length swap - nip ] if ; inline
: sequence-read-until ( separators stream -- seq sep/f ) : sequence-read-until ( seps stream -- seq sep/f )
[ find-sep ] keep [ find-separator ] keep
[ [ sequence-read-unsafe ] (read-into-new) ] [ next ] bi swap ; inline [ [ (sequence-read-unsafe) ] (read-into-new) ] [ next ] bi swap ; inline
! Writers ! Writers
M: growable dispose drop ; M: growable dispose drop ;