如果我有2个Streams，就像下面所示的方法一样publicStreamgetPendingTransaction(StreampendingTransactionStream,StreamprocessedTransactionStream){}并且我想根据某些标准(如iftransaction.getId()issameforanTransactionobjectpresentinpendingTransactionStreamandprocessedTransactionStreamthenthatobjectissameandwecancollecttheminalist.我