Angular/RxJS как описаться от пост запроса?

[karnotavr]

У меня есть простой post запрос, который я использую для создания сообщений. Проблема в том, что функция sendMessage() будет работать абсолютно одинаково при следующий вызовах после первого, отправляя одно и то же сообщение в БД даже уже с другими данными, пока не пересоздам таблицу. Обновление странички ничего не дает, так что проблема видимо в post запросе. Я пытался отписаться от запроса сразу же после его выполнения, но в таком случае сообщение даже не появляется в БД, причины чего мне непонятны. Подскажите, пожалуйста, решение. В ангуляре новичок.

Сервис

@Injectable({
  providedIn: 'root',
})
export class MessageService {
  private url = environment.apiUrl + '/message';

  constructor(private http: HttpClient) {}

  public create(request: CreateMessageRequest): Observable<void> {
    return this.http.post<void>(this.url, request);
  }
}

TS

public sendMessage(message: string){
    let request: CreateMessageRequest = {
      Message:  message, 
    }
    const req = this.messageService.create(request).subscribe();
    //req.unsubscribe(); если добавить, сообщение не пройдет в бд
  }

HTML

<form>
      <textarea #refVariable [value]="test" type="text" placeholder="Write message"></textarea>
      <button class="buttonTwo" type="submit" (click)="sendMessage(refVariable.value)"></button>
  </form>

P.S.: был также попробован такой код, но с идентичным результатом.

TS

export class DialogsComponent implements OnInit, OnDestroy {
constructor(private messageService: MessageService){}

private unsubscribe$ = new Subject<void>();
ngOnDestroy(): void {
    this.unsubscribe$.next();
    this.unsubscribe$.complete();
  }

public sendMessage(message: string){
    let request: CreateMessageRequest = {
      Message: message,
    }
    this.messageService.create(request)
    .pipe(takeUntil(this.unsubscribe$))
    .subscribe();
  }
}

Еще один нерабочий вариант

export class DialogsComponent implements OnInit, OnDestroy {
constructor(private messageService: MessageService){}
alive: boolean = true
ngOnDestroy(): void {
    this.alive = false;
  }

public sendMessage(message: string){
    let request: CreateMessageRequest = { 
      Message: message,
    }
    this.alive = true;
    this.messageService.create(request)
    .pipe(takeWhile(() => this.alive))
    .subscribe();
  }
}