// Copyright 2024 Matthew Rich <matthewrich.conf@gmail.com>. All rights reserved.

package interrogator;

import (
  "testing"
  "feudal/message"
)

func TestInterrogator(t *testing.T) {
  i := New()
  m := message.New("foo", i)
  go i.Send(m)
  r := <- i
  if r.Body() != "foo" {
    t.Errorf("Invalid message")
  }
}

func TestBufferedInterrogator(t *testing.T) {
  i := NewBuffered(1)
  m := message.New("foo", i)
  i.Send(m)
  r := <- i
  if r.Body() != "foo" {
    t.Errorf("Invalid message")
  }
}