
DIRECTORY 
Ascii, IO, Process, Rope, SimpleStreams, TypeScript, ViewerOps;
SimpleStreamsOnTypeScriptImpl: CEDAR MONITOR
IMPORTS IO, Process, Rope, SimpleStreams, TypeScript, ViewerOps =
BEGIN 

MyRec: TYPE = RECORD [
ts: TypeScript.TS,
alive: BOOL м TRUE
];

TSCreateSimpleStreams: SimpleStreams.CreateProcType = {
hh: REF MyRec м NEW[MyRec];
IF Rope.IsEmpty[header] THEN header м "Simple Stream";
hh.ts м TypeScript.Create[info: [name: header]];
out м IO.CreateStream[outputStreamProcs, hh];
in м IO.CreateStream[inputStreamProcs, hh];
hasEcho м FALSE;
};

inputStreamProcs: REF IO.StreamProcs м IO.CreateStreamProcs[
variety: $input, 
class: $X11SimpleStreamsInput,
charsAvail: MyCharsAvail,
getChar: MyGetChar,
close: MyCloseBoth
];

outputStreamProcs: REF IO.StreamProcs м IO.CreateStreamProcs[
variety: $output, 
class: $X11SimpleStreamsOutput,
putChar: MyPutChar,
eraseChar: MyEraseChar,
close: MyCloseBoth
];

MyPutChar: PROC [self: IO.STREAM, char: CHAR] = {
hh: REF MyRec  = NARROW[self.streamData];
IF hh.ts.destroyed THEN GOTO oops;
IF char=Ascii.BS 
THEN TypeScript.BackSpace[hh.ts ! TypeScript.Destroyed => {GOTO oops}]
ELSE TypeScript.PutChar[hh.ts, char ! TypeScript.Destroyed => {GOTO oops}];
EXITS oops => {MyCloseBoth[self]; ERROR IO.Error[StreamClosed, self]};
};

MyGetChar: PROC [self: IO.STREAM] RETURNS [ch: CHAR] = {
hh: REF MyRec  = NARROW[self.streamData];
IF hh.ts.destroyed THEN GOTO oops;
ch м TypeScript.GetChar[hh.ts ! TypeScript.Destroyed => {GOTO oops}];
IF ch=4C THEN MyCloseBoth[self]; --**works only if somebody is asking for input...
EXITS oops => {MyCloseBoth[self]; ERROR IO.Error[StreamClosed, self]};
};

MyEraseChar: PROC [self: IO.STREAM, char: CHAR] = {
hh: REF MyRec  = NARROW[self.streamData];
IF hh.ts.destroyed THEN GOTO oops;
TypeScript.BackSpace[hh.ts ! TypeScript.Destroyed => {GOTO oops}];
EXITS oops => {MyCloseBoth[self]; ERROR IO.Error[StreamClosed, self]};
};

MyCharsAvail: PROC [self: IO.STREAM, wait: BOOL] RETURNS [n: INT] = {
hh: REF MyRec  = NARROW[self.streamData];
IF hh.ts.destroyed THEN GOTO oops;
IF wait THEN {
WHILE ~TypeScript.CharsAvailable[hh.ts ! TypeScript.Destroyed => GOTO oops]  DO
Process.Pause[1];
ENDLOOP;
RETURN [1]
};
IF TypeScript.CharsAvailable[hh.ts ! TypeScript.Destroyed => GOTO oops]
THEN RETURN [1]
ELSE RETURN [0];
EXITS oops => {MyCloseBoth[self]; n м LAST[INT]};
};

SetDead: ENTRY PROC [hh: REF MyRec] RETURNS [was: BOOLмFALSE] = {
ENABLE UNWIND => NULL;
IF hh#NIL THEN {was м hh.alive; hh.alive м FALSE};
};

MyCloseBoth: PROC [self: IO.STREAM, abort: BOOL м FALSE]  = {
hh: REF MyRec  = NARROW[self.streamData];
wasAlive: BOOL м SetDead[hh];
IF wasAlive THEN {
ViewerOps.DestroyViewer[hh.ts]
};
};

SimpleStreams.ImplementCreate[$TypeScript, TSCreateSimpleStreams];
END.


    ╬  
SimpleStreamsOnTypeScriptImpl.mesa
Copyright ╙ 1988, 1992 by Xerox Corporation.  All rights reserved.
Christian Jacobi, September 2, 1988 11:31:49 am PDT
Christian Jacobi, March 27, 1992 4:49 pm PST
Э╩D  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЩ"KЪЬ
╧eЬ7ЩBKЪЬ0╧kЩ3KЩ,ЧKШ ЪЮ	ЬШ
KЪЬЮЬ6Ш?ЧЪ╧nЬЮЬЮШ,KЪЮЬЮЬ7ШAЧKЪЮЬШKШ ЪЬЮЬЮЬШKЪЬЮЬШKЪЬЮЬЮШKЪЬШЧKШ ЪЯЬ"Ш7KЪЬЮЬ	ЮЬШKЪЮЬЮЬШ6KШ0KЪЬЮЬ%Ш-KЪЬЮЬ$Ш+KЪЬ
ЮЬШKЪЬШЧKШ Ц"cedar" styleЪЬЮЬЮЬЮЬШ<KЦ"cedar" styleШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШЧKЦ"cedar" styleШ Ц"cedar" styleЪЬЮЬЮЬЮЬШ=KЦ"cedar" styleШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШKЪЬШKЦ"cedar" styleЪЬШKЦ"cedar" styleЪЬШЧKШ Ъ
Я	ЬЮЬЮЬЮЬЮЬШ1KЪЬЮЬ
ЮЬШ)KЪЮЬЮЬЮЬШ"ЪЮЬЮЬШKЪЮЬ7ЮЬШFKЪЮЬ;ЮЬШKЧKЪЮЬЮЬЮЬШFKЪЬШKШ ЧЪЯ	ЬЮЬЮЬЮЬЮЬЮЬШ8KЪЬЮЬ
ЮЬШ)KЪЮЬЮЬЮЬШ"KЪЬ9ЮЬШEKЪЮЬЮЬ╧c1ШRKЪЮЬЮЬЮЬШFKШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШ3KЪЬЮЬ
ЮЬШ)KЪЮЬЮЬЮЬШ"KЪЬ6ЮЬШBKЪЮЬЮЬЮЬШFKШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬШEKЪЬЮЬ
ЮЬШ)KЪЮЬЮЬЮЬШ"ЪЮЬЮЬШЪЮЬ<ЮЬЮШOKЪЬШKЪЮЬШЧKЪЮЬШ
KШЧЪЮЬ;ЮЬШGKЪЮЬЮЬШKЪЮЬЮЬШЧKЪЮЬ!ЮЬЮЬШ1KШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬШAKЪЮЬЮЬЮЬШKЪЮЬЮЬЮЬЮЬШ2KЪЬШЧKШ Ъ
ЯЬЮЬЮ	Ь	ЮЬЮЬШ=KЪЬЮЬ
ЮЬШ)KЪЬ
ЮЬШЪЮЬ
ЮЬШKЪЬШKЪЬШЧKШЧKШ KЪЬBШBKЪЮЬШKШЧ ЕЧ    
╥  ф  