(cmd *cobra.Command, cli *cli, streamID string)
| 853 | } |
| 854 | |
| 855 | func fetchRecentDeliveries(cmd *cobra.Command, cli *cli, streamID string) ([]*management.EventDelivery, error) { |
| 856 | var deliveries *management.EventDeliveryList |
| 857 | err := ansi.Waiting(func() (err error) { |
| 858 | deliveries, err = cli.api.EventStream.ListDeliveries(cmd.Context(), streamID, |
| 859 | management.Parameter("take", "100"), |
| 860 | ) |
| 861 | return err |
| 862 | }) |
| 863 | if err != nil { |
| 864 | return nil, err |
| 865 | } |
| 866 | return deliveries.Deliveries, nil |
| 867 | } |
| 868 | |
| 869 | func (c *cli) eventStreamPickerOptions(ctx context.Context) (pickerOptions, error) { |
| 870 | list, err := c.api.EventStream.List(ctx) |
no test coverage detected