These methods can be used in .nrx files for Pipeline stages.
Clicking on one of the 'Source' name buttons will display only those methods from the same source. Clicking on the 'All' button will display them from all sources.
Name | Returns | Method | Source |
---|---|---|---|
Description | Signals | ||
Comment | |||
addpipe | addpipe(apipe=pipe) | stage | |
Stage level addpipe | |||
arg | Rexx | arg() | stage |
Get the argument(s) | |||
arg(i=Rexx) | Rexx | arg(i=Rexx) | stage |
If it exists get value at arg[i] | |||
arg(o=Object) | Object | arg(o=Object) | stage |
Get the argument(s) | |||
BuildIRange | Rexx | BuildIRange(a=Rexx,p=Rexx ' ') | IRange |
Extract contents of ranges into a string | |||
BuildIRangeExit | Rexx | BuildIRangeExit(r=Rexx,str=Rexx,pad=Rexx ' ') | IRange |
Return an expression that evaluates to the desired range | |||
BuildIRangeStrict | Rexx | BuildIRangeStrict(a=Rexx,p=Rexx ' ') | IRange |
Extract contents of ranges into a string | StageError | ||
callpipe | int | callpipe(apipe=pipe) | stage |
Stage level callpipe | ThreadQ | ||
checkOut | int | checkOut(r=int 0) | stage |
Check all output streams | |||
| |||
commit | int | commit() | stage |
Return the return code of the pipe (so far) | |||
commit | int | commit(n=int) | stage |
Set the commit level of this stage to n | ThreadQ | ||
counter | int | counter(i=int 0) | stage |
increment external wait counter | |||
DelayRingBuf | Rexx | DelayRingBuf(string = Rexx) | RingBuf |
Adds a Rexx string to a ring buffer | |||
existing data is returned as a Rexx string. | |||
Delimiter | Rexx | Delimiter() | DString |
The delimiter character of the Link.,"" for no string found or "hex" or "bin" ranges. | |||
doSetup | boolean | doSetup() | stage |
Is the do we need to do a setup because of args? | |||
DString | Delimited String | ||
Delimited stringsAll strings are Rexx DString(delimitedString additional_string) returns an object of type DString for the value of a "delimitedstring" at the begining of the input Methods on DString:
A delimited character string is written between two occurrences of a delimiter character, as a hexadecimal literal, or as a binary literal. The delimiter cannot be blank and it must not occur within the string. Two adjacent delimiter characters represent the null string. It is suggested that a special character be used as the delimiter, but this is not enforced. However, it is advisable not to use alphanumeric characters, because a future release might add a keyword or a number as a valid option to a built-in program where only a delimited string is valid today. A hexadecimal literal is specified by a leading H or X followed by an even number of hexadecimal digits. A binary literal is specified by a leading B followed by a string of 0 and 1; the number of binary digits must an integral multiple of eight. The keyword STRING can be used to specify that the delimited string contains a string that is terminated by delimiter characters. This acts as a place-holder so that any nonblank character can be used as the delimiter character. Note that this use of the keyword is in addition to a keyword that is recognised by a built-in program. (Thus, "split string string xabcx") | |||
DString | DString | DString(in_string = Rexx '') | DString |
Returns a DString from left of in_string | |||
dump | dump() | stage | |
Make it easier to dump | |||
Emsg | Emsg(n=int,s=String) | stage | |
Issue an error, with the stage name. | ThreadQ | ||
Kills the pipe | |||
EndChar | Rexx | EndChar(n = Rexx null) | IRange |
Sets end column, returns old end column | |||
EndCol | Rexx | EndCol() | IRange |
Returns end column | |||
eofReport | eofReport(a=Rexx) | stage | |
Set eofReporting options | StageError | ||
a='CURRENT' | 'ALL' | 'ANY' | |||
error | Error(n=int,s=String) | stage | |
Issue an error | StageError | ||
Does not kill the pipe | |||
exit | exit(c=int) | stage | |
Exit a stage severing all output streams | ThreadQ | ||
getAnycase | Rexx | getAnycase(argstr = Rexx) | utils |
Checks first word of argstr for ANYCASE or alias, uses caseless compare. | |||
Returns : 1 = found ANYCASE 0 = not found -1 = found RESPECTCASE | |||
getIRanges | IRange[] | getIRanges(in_string = Rexx, word_seperator = Rexx '', field_seperator = Rexx null) | IRange |
getKeyWord | Rexx[] | getKeyWord(argString, keyword, minKeyLength = 0, type = 'K') | utils |
Search an argument string for key word and value | |||
This searches a string for a word or its abbreviation. It is for searching argument strings for key words. A minKeyLength of '' or 0 means the full length is needed. The search is case independent. What it returns depends on the Type. Type values (Only the first character is used):
It returns a Rexx Indexed string of what it found including the original string with the keyword (and Subword, Dstring, or Qword) removed. If the key word is not found the original string is returned. A key of "" and type of "DString" will search for a Dstring at the beginning of the argString. Note: This version, when searching for a keyword, does not respect quoted strings or delimited strings. It simply finds the first word that matches. returns:
| |||
getName | String | getName() | stage |
Get the thread name | |||
getPipeName | Rexx | getPipeName() | stage |
getRexx | Rexx number | getRexx(n=Rexx) | stage |
Get variable context | |||
GetRingBuf | Rexx | GetRingBuf() | RingBuf |
returns a ring buffer as a Rexx string | |||
The starting point is where new data would be inserted. | |||
GetXorc | Rexx | GetXorc(xorc_string) | utils |
Returns a Rexx character | |||
GetXRange | Rexx | GetXRange(argstring) | utils |
Returns Rexx string of characters in the xrange | |||
Inspects the first word of argstr.
Returns a string of characters in the collating order
inclusive of the first and last. (xorc can be the word BLANK.)
Returns '' if first word is not a valid XRange.
xrange: |--+--xorc---------+--| +--xorc-xorc----+ +--xorc.number--+ | |||
go | go() | stage | |
Start a stage selecting default input and output streams | ThreadQ | ||
input | boolean | input() | Link |
get the data in a link | |||
inStream | inStream(inStream=int,link=link,callPipe=boolean) | stage | |
Replace output of stage with link | StageError | ||
inStreamNumber | int | inStreamNumber() | stage |
Current input stream | |||
inStreamState | int | inStreamState() | stage |
Returns:
| |||
IRange | Input Range | ||
|--+-range--------------+------------| | ⬐----------+ | +-(--+----range-+--)-+ +-(strict-range-+--)-+ range: ⬐------------------------------+ |-+--+--------------------------+-+--------▶ +-+-FIELDSEParator-+--xorc-+ +-WORDSEParator--+ ⬐----------------------------------+ ▶--+--+------------------------------+-+---▶ +-SUBSTRing--| rangePart |--OF-+ ▶--| rangePart |----| rangePart: |--+------------+--------------▶ +-| wrdSep |-+ +-| fldSep |-+ ▶--+-snumorstar------------+--------| +-snumorstar;snumorstar-+ +-numorstar-numorstar---+ +-numorstar.number---+ wrdSep: |--+------------------------+--Words------| +-+-WORDSEParator-+-xorc-+ +-WS------------+ fldSep: |--+-------------------------+--Fields----| +-+-FIELDSEParator-+-xorc-+ +-FS-------------+ Examples: 1-* word 5 1;-1 -18;28 field 4 An input range is specified as a column range, a word range, a field range. A single column is specified by a signed number. Negative numbers are relative to the end of the record; thus, -1 is the last column of the record. A column range is specified as two signed numbers separated by a semicolon or as a range. When a semicolon is used, the first number specifies the beginning column and the second number specifies the ending column. When the beginning and end of a field are relative to the opposite ends of the record, the input field is treated as a null field if the ending column is left of the beginning column. A word range is specified by the keyword WORDS, which can be abbreviated down to W. Words are separated by one or more blanks. The default blank character is X'20'. Specify the keyword WORDSEPARATOR to specify a different word separator character. WORDSEPARATOR can be abbreviated down to WORDSEP; WS is a synonym. A field range is specified by the keyword FIELDS, which can be abbreviated down to F. Fields are separated by tabulate characters. Two adjacent tabulate characters enclose a null field. (Note the difference from words.) The default horizontal tab character is X'09'. Specify the keyword FIELDSEPARATOR to specify a different field separator character. FIELDSEPARATOR can be abbreviated down to FIELDSEP; FS is a synonym. | |||
isFirstStage | boolean | isFirstStage() | stage |
get if this stage is first working stage in pipe fragment. Ignores precedding COMMENT stage(s) | |||
Length | Rexx | Length() | IRange |
Returns length of selection | |||
link | link | link(s=stage, n=int, d=boolean) | Link |
construct a link that defines a stream for a called pipe | |||
Links are used for two purposes.
| |||
link | link | link(l=link,s=stage,n=int,d=boolean) | Link |
construct a link to save the previous connections in a pnode | |||
list | link | list() | Link |
get the data in a link | |||
maxInputStream | int | maxInputStream() | stage |
Max defined Input stream | |||
maxOutputStream | int | maxOutputStream() | stage |
Max defined Output stream | |||
mrc | Rexx number | mrc() | stage |
Get the max return code | |||
nocommit | nocommit() | stage | |
Do not commit to -1 at first peek, readto or output | |||
number | Rexx | Number() | IRange |
Returns start column | |||
object2rexx | Rexx | object2rexx(a=Object) | utils |
Convert an object to Rexx if possible | StageError | ||
object2string | String | object2string(a=Object) | utils |
Convert an object to a string if possible | StageError | ||
output | output(d=Object) | stage | |
Output data to output stream | StageError ThreadQ | ||
Note: no StageError is raised when outputing to an unconnected stream
though a StageError will occur outputing to a severed stream. After
njPipes has processed the sever the severed stream is seen as unconnected.
ie. you only see a sever once for a stream/connection pair.
| |||
outStream | outStream(out_stream=int,link=link,iscallpipe=boolean) | stage | |
Replace input of a stage with link | StageError | ||
outStreamNumber | int | outStreamNumber() | stage |
Current output stream | |||
outStreamState | int | outStreamState() | stage |
Returns:
| |||
peekto | Object | peekto() | stage |
Peek at input data... | StageError ThreadQ | ||
pipStop | pipStop() | stage | |
ThreadQ | |||
pos | int | pos(haystack=byte[],needle=byte[]) | utils |
Prefix | Rexx | Prefix(n = Rexx null) | IRange |
Returns the string before the IRange string. | |||
putLink | putLink(k=Rexx,o=link) | stage | |
PutRingBuf | PutRingBuf(s = Rexx) | RingBuf | |
Adds a Rexx string to a ring buffer, after the preceding data. | |||
QWord | Quoted Word | ||
A Qword is an optionally quoted word. If it contains spaces, it must be quoted. The quote marks may be single or double. | |||
rc | Rexx number | rc() | stage |
Get the return code | |||
rc | int | rc(e=StageError) | stage |
Set the return code | |||
rc | int | rc(n=int) | stage |
Set the return code | |||
readto | Object | readto() | stage |
Read data from input pnode | StageError ThreadQ | ||
Regex String | Regular Expresion | ||
|--regex_string--| Examples:
A regular expression string, or regex_string, defines a search pattern for strings. The search pattern can be anything from a simple character, a fixed string, or a complex expression containing special characters describing the pattern. Using regular expressions can be very powerful. Also cn be very hard to read, and nearly so to write. Regular expressions are used in many different programming languages, and have several dialects. NetRexx Pipelines uses its underlying Java's version. | |||
Residue | Rexx | Residue(n = Rexx null) | IRange |
Residue | Rexx | Residue() | DString |
What is left of input string afte DString has been removed | |||
rexxArg | Rexx | rexxArg(a=Rexx) | utils |
"" | |||
Apparently deprciated and returns ''. Did return the number of Rexx object arguments. | |||
RingBuf | RingBuf | RingBuf(i = Rexx) | RingBuf |
Creates an empty ring buffer of size | |||
run | run() | stage | |
Runable body of stage | |||
Must be overridden by the stage. Called by system to run the stage. | |||
Sel1IRange | Rexx | Sel1IRange(str=Rexx,pad=Rexx) | IRange |
Returns the range out of string | |||
Sel1IRangeExit | Rexx | Sel1IRangeExit(str=Rexx,pad=Rexx) | IRange |
Generate a command to extract one IRange element | |||
selectAnyInput | selectAnyInput() | stage | |
Select any input stream | |||
The most reciently referenced stream with input is selected | |||
selectInput | selectInput(stream=int) | stage | |
Select an input stream | StageError | ||
A stage error will occur if the stream does not exist | |||
selectOutput | selectOutput(stream=int) | stage | |
Select an output stream | StageError | ||
A stage error will occur if the stream does not exist | |||
SelIRange | Rexx | SelIRange(str=Rexx,pad=Rexx ' ') | IRange |
Returns an IRange object for a range, including subranges, out of string | |||
Separator | Rexx | Separator(n = Rexx null) | IRange |
setArg | setArg(a=Rexx,d=boolean 0) | stage | |
Set the arguments(s) | |||
setArg | setArg(o=Object,d=boolean 0) | stage | |
Set the arguments(s) | |||
setDebug | setDebug(level=int) | stage | |
setName | setName(name=String) | stage | |
Set the thread name | |||
setRelPriority | setRelPriority(n=int) | stage | |
Set Relative Priority by adding n. | |||
setRunaway | setRunaway(i=int) | stage | |
Set stall time | |||
severCallback | severCallback(type=boolean,stream=int) | stage | |
Callback to be overridden by threaded stages needing to interrupt blocked threads | StageError | ||
severInput | severInput() | stage | |
Sever an input stream passing EndOfData to output pnode | StageError | ||
The sever is indicated by seting inn.outs to null, this
causes output to get an exception. The inn.ins.inn is
also set to null to trigger readto/peekto/selectanyinput
for eofreport options. We have to be carefull not to
restore inn to easily so the sever is not missed...
| |||
severOutput | severOutput() | stage | |
StageError | |||
Once the sever is processed by the reciever the sin or
sout variable is set to -99 to allow selectinput/output
| |||
shortStreams | shortStreams() | stage | |
Short the current input and output | StageError ThreadQ | ||
The pnode for the input stream is bypassed and the stages current streams are unlinked. If the stream lists are empty a stageError is raised to end the stage. | |||
sortInsertInto | Rexx[] | sortInsertInto(list = Rexx, new = Rexx, strict = Rexx 0) | utils |
Insert a new item into a sorted list in a Rexx indexed variable. Returns the list with new inserted. | |||
Indexed by integers from 1.
Index 0 is a count of the other values. If strict = 1 or the first charater is 'S' or 's', then strict compare, <<, is used, otherwise normal compare, <, is used. Example: mylist = Rexx '' -- new empty list mylist[0] = 0 -- number of items in the list sortInsertInto(mylist, 'first') -- into empty list sortInsertInto(mylist, 'early') -- before anything in the list sortInsertInto(mylist, 'last') -- after everyting in the list sortInsertInto(mylist, 'inserted') -- somewhere in the middle of the list, the typical case loop i = 0 to list[0] say i ':' list[i] end 0 : 4 1 : early 2 : first 3 : inserted 4 : last | |||
stage | stage | stage() | Link |
Get the data in a link | |||
StageError | StageError(r=int,s=String) | stage | |
stageExit | boolean | stageExit(pInfo=Rexx,code=Rexx) | utils |
Change the unprocessed pipe definition, the definition of the current stage | StageError | ||
Called by the compiler. | |||
StartChar | Rexx | StartChar(n = Rexx null) | IRange |
Sets start column, returns old start column | |||
StartCol | Rexx | StartCol() | IRange |
Returns start column | |||
stream | int | stream() | Link |
Get the data in a link | |||
Strict | boolean | Strict() | IRange |
String | Rexx | String() | DString |
String found from delimited string | |||
SubIRange | IRange | SubIRange(n = IRange null, d = 1) | IRange |
suspend | suspend() | stage | |
Let all the other stages go before we start again | ThreadQ | ||
toRexx | Rexx | toRexx() | IRange |
Returns readable data about an IRange | |||
toString | String | toString() | IRange |
Returns readable data about an IRange | |||
Type | Rexx | Type() | IRange |
XorC | Hex number or Character | ||
| |||
Xrangerx | Rexx | xrangerx(fc='',lc='') | utils |
Just like classic Rexx BIF xrange(). Returns a string of characters in the collating order inclusive of the first and last. Wraps around 0xFF to 0x00 if needed. |