将过滤器应用于颤动中的Supadase流

Question

我想将一个过滤器应用于Supadase的流，但找不到任何如何实现这一点的示例。这是我的功能(没有过滤器(：

Stream<List<Map<String, dynamic>>> _getProducts() {
final response = supabase.from('products').stream().execute();
return response;
}

我想对流应用一个简单的"eq"过滤器。这就是未来的样子：

Future<PostgrestResponse> _getProducts() async {
final user = supabase.auth.currentUser;
final response =
await supabase.from('products').select().eq('uuid', user!.id).execute();
return response;
}

不幸的是，应用相同的select((.eq((逻辑不起作用。

谢谢。

Answer 1

这应该适用于您。

Future<List<Map<String, dynamic>>> _getProducts() async {    
final user = supabase.auth.currentUser;    
final response = await 
supabase.from('products:uuid=eq.${user!.id}').stream(['uuid']).execute();   
return response;  
}