@@ -170,64 +170,6 @@ export default class LDClientImpl implements LDClient {
170170 return this . checkedContext ;
171171 }
172172
173- private createStreamListeners (
174- context : Context ,
175- identifyResolve : any ,
176- ) : Map < StreamEventName , ProcessStreamResponse > {
177- const listeners = new Map < StreamEventName , ProcessStreamResponse > ( ) ;
178-
179- listeners . set ( 'put' , {
180- deserializeData : JSON . parse ,
181- processJson : async ( evalResults : Flags ) => {
182- this . logger . debug ( `Stream PUT: ${ Object . keys ( evalResults ) } ` ) ;
183-
184- // mapping flags to item descriptors
185- const descriptors = Object . entries ( evalResults ) . reduce (
186- ( acc : { [ k : string ] : ItemDescriptor } , [ key , flag ] ) => {
187- acc [ key ] = { version : flag . version , flag } ;
188- return acc ;
189- } ,
190- { } ,
191- ) ;
192- await this . flagManager . init ( context , descriptors ) . then ( identifyResolve ( ) ) ;
193- } ,
194- } ) ;
195-
196- listeners . set ( 'patch' , {
197- deserializeData : JSON . parse ,
198- processJson : async ( patchFlag : PatchFlag ) => {
199- this . logger . debug ( `Stream PATCH ${ JSON . stringify ( patchFlag , null , 2 ) } ` ) ;
200- this . flagManager . upsert ( context , patchFlag . key , {
201- version : patchFlag . version ,
202- flag : patchFlag ,
203- } ) ;
204- } ,
205- } ) ;
206-
207- listeners . set ( 'delete' , {
208- deserializeData : JSON . parse ,
209- processJson : async ( deleteFlag : DeleteFlag ) => {
210- this . logger . debug ( `Stream DELETE ${ JSON . stringify ( deleteFlag , null , 2 ) } ` ) ;
211-
212- this . flagManager . upsert ( context , deleteFlag . key , {
213- version : deleteFlag . version ,
214- flag : {
215- ...deleteFlag ,
216- deleted : true ,
217- // props below are set to sensible defaults. they are irrelevant
218- // because this flag has been deleted.
219- flagVersion : 0 ,
220- value : undefined ,
221- variation : 0 ,
222- trackEvents : false ,
223- } ,
224- } ) ;
225- } ,
226- } ) ;
227-
228- return listeners ;
229- }
230-
231173 private createIdentifyPromise ( timeout : number ) : {
232174 identifyPromise : Promise < void > ;
233175 identifyResolve : ( ) => void ;
0 commit comments