net.ranides.assira.lexer
Class ByteStreamer<UserArgument>

java.lang.Object
  net.ranides.assira.lexer.ByteStreamer<UserArgument>

Type Parameters:

UserArgument -

public class ByteStreamer<UserArgument>
extends Object

Strumień przetwarzający kolejno elementy zbioru przydatny przy pisaniu lexerów ad hoc. Żadna funkcjonalność związana z obsługą gramatyki nie istnieje. Przydatny do przetwarzania sekwencji sterujących, kodów escape'ujących w stringach, wzorców podstawieniowych etc

Bardziej ściśle: do przetwarzania formatów, w których bezkontekstowe symbole nie są zagnieżdżane rekurencyjnie.

Author:

ranides

Constructor Summary

ByteStreamer(ByteConsumer<UserArgument> consumer)
Tworzy nowy strumień, który przekazuje wyodrębnione fragmenty do podanego konsumenta.

Method Summary

void	close() Kończy przetwarzanie danych
boolean	end() Sprawdza, czy przetworzono wszystkie dostępne dane.
void	flush() Odrzuca bieżący fragment i rozpoczyna przetwarzanie nowego od aktualnej pozycji kursora.
void	flush(UserArgument extra) Wysyła bieżący fragment do odbiorcy.
void	flush(UserArgument extra, int lclip, int rclip) Wysyła bieżący fragment do odbiorcy, ignorując left pierwszych znaków oraz right ostatnich.
byte	get() Odczytuje element ze strumienia i przesuwa kursor do przodu.
void	open(byte[] input) Rozpoczyna przetwarzanie kolejnej porcji danych
byte	peek() Odczytuje element ze strumienia nie przesuwając kursora
boolean	pending() Sprawdza,czy przetwarzanie wykorzystało wszystkie przekazane dane
void	send(UserArgument extra, byte... data) Wysyła do odbiorcy fragment o wskazanej treści
void	skip() Pomija element

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ByteStreamer

public ByteStreamer(ByteConsumer<UserArgument> consumer)

Tworzy nowy strumień, który przekazuje wyodrębnione fragmenty do podanego konsumenta.

Parameters:

consumer -

Method Detail

get

public byte get()

Odczytuje element ze strumienia i przesuwa kursor do przodu.

Returns:

peek

public byte peek()

Odczytuje element ze strumienia nie przesuwając kursora

Returns:

skip

public void skip()

Pomija element

end

public boolean end()

Sprawdza, czy przetworzono wszystkie dostępne dane.

Returns:

send

public void send(UserArgument extra,
                 byte... data)

Wysyła do odbiorcy fragment o wskazanej treści

Parameters:

extra -

data -

flush

public void flush()

Odrzuca bieżący fragment i rozpoczyna przetwarzanie nowego od aktualnej pozycji kursora.

flush

public void flush(UserArgument extra,
                  int lclip,
                  int rclip)

Wysyła bieżący fragment do odbiorcy, ignorując left pierwszych znaków oraz right ostatnich. Następnie rozpoczyna przetwarzanie nowego fragmentu rozpoczynającego się od aktualnej pozycji kursora.

Parameters:

extra -

lclip -

rclip -

flush

public void flush(UserArgument extra)

Wysyła bieżący fragment do odbiorcy. Następnie rozpoczyna przetwarzanie nowego fragmentu od aktualnej pozycji kursora.

Parameters:

extra -

open

public void open(byte[] input)

Rozpoczyna przetwarzanie kolejnej porcji danych

Parameters:

input -

Throws:

IllegalStateException - jeśli strumień jest w trakcie przetwarzania danych.

close

public void close()

Kończy przetwarzanie danych

pending

public boolean pending()

Sprawdza,czy przetwarzanie wykorzystało wszystkie przekazane dane

Returns: