@@ -53,6 +53,7 @@ def decode(self, input, errors='strict'):
53
53
return _codecs .__truffle_decode (input , self .encoding , errors )
54
54
55
55
56
+ # TODO - the incremental codec and reader/writer won't work well with stateful encodings, like some of the CJK encodings
56
57
class TruffleIncrementalEncoder (codecs .IncrementalEncoder ):
57
58
def __init__ (self , encoding , * args , ** kwargs ):
58
59
super ().__init__ (* args , ** kwargs )
@@ -62,13 +63,13 @@ def encode(self, input, final=False):
62
63
return _codecs .__truffle_encode (input , self .encoding , self .errors )[0 ]
63
64
64
65
65
- class TruffleIncrementalDecoder (codecs .IncrementalDecoder ):
66
+ class TruffleIncrementalDecoder (codecs .BufferedIncrementalDecoder ):
66
67
def __init__ (self , encoding , * args , ** kwargs ):
67
68
super ().__init__ (* args , ** kwargs )
68
69
self .encoding = encoding
69
70
70
- def decode (self , input , final = False ):
71
- return _codecs .__truffle_decode (input , self .encoding , self . errors )[ 0 ]
71
+ def _buffer_decode (self , input , errors , final ):
72
+ return _codecs .__truffle_decode (input , self .encoding , errors , final )
72
73
73
74
74
75
class TruffleStreamWriter (codecs .StreamWriter ):
0 commit comments