hg/stx-goodies-xtreams: substreams/Xtreams__WriteSubstream.st@871b930fcf3d (annotated)

4 20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	1	"{ Package: 'stx:goodies/xtreams/substreams' }"
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	2
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	3	"{ NameSpace: Xtreams }"
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	4
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	5	WriteStream subclass:#WriteSubstream
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	6	instanceVariableNames:'destinationAtEnd closeBlock substreamClosed'
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	7	classVariableNames:''
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	8	poolDictionaries:''
22 e0653bbdbe61 added XtreamsPool to fix DefaultBufferSize; set proper category names mkobetic parents: 4 diff changeset	9	category:'Xtreams-Substreams'
4 20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	10	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	11
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	12	WriteSubstream comment:'This is abstract superclass of all substreams. Substreams normally don''t close their underlying source, their closing behavior is customized via closeBlock.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	13
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	14	Instance Variables
109 9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	15	destinationAtEnd <Boolean> flags end of the destination
9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	16	closeBlock <BlockClosure> unary block invoked in response to #close, allows customizing closing behavior
9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	17	substreamClosed <Boolean> flags the end of the receiver
4 20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	18
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	19	'
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	20	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	21
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	22
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	23	!WriteSubstream class methodsFor:'private'!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	24
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	25	slice: sliceBlock close: closeBlock
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	26	\| substream \|
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	27	substream := nil.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	28	^[substream == nil ifFalse:
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	29	[substream substreamClosed ifFalse: [substream close].
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	30	substream subseekend.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	31	substream destinationAtEnd ifTrue: [Incomplete zero raise]].
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	32	substream := sliceBlock value]
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	33	reading
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	34	closeBlock: closeBlock;
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	35	yourself
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	36	! !
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	37
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	38	!WriteSubstream methodsFor:'accessing'!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	39
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	40	closeBlock
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	41	^closeBlock
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	42	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	43
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	44	closeBlock: anObject
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	45	closeBlock := anObject
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	46	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	47
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	48	insert: anInteger from: aSequenceableCollection at: startIndex
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	49	[destination insert: anInteger from: aSequenceableCollection at: startIndex] on: Incomplete do: [:incomplete \|
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	50	destinationAtEnd := true.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	51	incomplete pass].
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	52	^anInteger
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	53	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	54
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	55	put: anObject
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	56	[destination put: anObject] on: Incomplete do: [:incomplete \|
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	57	destinationAtEnd := true.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	58	incomplete pass]
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	59	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	60
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	61	write: anInteger from: aSequenceableCollection at: startIndex
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	62	[destination write: anInteger from: aSequenceableCollection at: startIndex] on: Incomplete do: [:incomplete \|
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	63	destinationAtEnd := true.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	64	incomplete pass].
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	65	^anInteger
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	66	! !
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	67
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	68	!WriteSubstream methodsFor:'initialize-release'!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	69
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	70	close
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	71	closeBlock cull: self.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	72	substreamClosed := true
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	73	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	74
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	75	contentsSpecies
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	76	^destination contentsSpecies
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	77	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	78
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	79	on: aDestination
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	80	super on: aDestination.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	81	closeBlock := [].
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	82	destinationAtEnd := false.
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	83	substreamClosed := false
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	84	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	85
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	86	subseekend
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	87	! !
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	88
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	89	!WriteSubstream methodsFor:'testing'!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	90
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	91	destinationAtEnd
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	92	^destinationAtEnd
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	93	!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	94
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	95	substreamClosed
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	96	^substreamClosed
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	97	! !
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	98
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	99	!WriteSubstream class methodsFor:'documentation'!
20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	100
109 9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	101	version_HG
9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	102
9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	103	^ '$Changeset: <not expanded> $'
4 20abcbb9eb33 first cut Martin Kobetic <mkobetic@gmail.com> parents: diff changeset	104	! !
109 9587e2df7029 Merged in latest version Jan Vrany <jan.vrany@fit.cvut.cz> parents: 67 diff changeset	105

author	Martin Kobetic
	Sun, 17 Nov 2013 00:02:08 -0500
changeset 131	871b930fcf3d
parent 109	9587e2df7029
permissions	-rw-r--r--