Androidアプリ開発で、Wearとdata itemを同期する方法について

Question

環境

Windows 10 pro
Android Studio : 最新バージョン
エミュレーター : Android Studioに付属の Wear OS SQUARE API26 (x86)
スマートフォン : Zenfone 2 laser (6.0.1)
エミュレーターとスマートフォンは、このサイトの通りに接続している(bluetoothデバッグはOFF)。Watch Face?をスマホで変更したらスマートウォッチ側でも変更されたので接続は正常

質問内容

以下のやりたいことをする上で以下の問題が発生したので、解決方法を知りたいです
よろしくお願いします

やりたいこと

最終的には、スマートウォッチとスマートフォン両方でデータを同期しようとしています。
その前段階として、スマートフォン側でボタンを押すとcountという変数の値が+1され、countの値をスマートウォッチで表示するということに挑戦中です。

発生している問題・エラーメッセージ

エラーメッセージ

該当のソースコード

スマートフォン側のソースコード
import系は抜いています

public class MainActivity extends Activity implements DataClient.OnDataChangedListener {
    private DataClient mDataClient;
    private static final String TAG = "MainActivity";
    private static final String DATA_PATH  = "/data";
    private static final String DATA_KEY = "data";
    private int count = 0;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Button btClick = findViewById(R.id.btSend);
        btSendListener listener = new btSendListener();
        btClick.setOnClickListener(listener);
    }

    private class btSendListener implements View.OnClickListener {
        @Override
        public void onClick(View view) {
            TextView output = findViewById(R.id.tvResult);
            output.setText("送信中");

            PutDataMapRequest dataMap = PutDataMapRequest.create(DATA_PATH);
            dataMap.getDataMap().putInt(DATA_KEY, count);

            PutDataRequest putDataReq =dataMap.asPutDataRequest();
            putDataReq.setUrgent();
            Task<DataItem> dataItemTask =
                    Wearable.getDataClient(getApplicationContext()).putDataItem(putDataReq);

//            try {
//                DataItem dataItem = Tasks.await(dataItemTask);
//            } catch (ExecutionException e) {
//                e.printStackTrace();
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }

            output.setText(Integer.toString(count));

            count++;
        }
    }

    @Override
    protected void onResume() {
        super.onResume();
        Wearable.getDataClient(this).addListener(this);
    }

    @Override
    protected void onPause() {
        super.onPause();
        Wearable.getDataClient(this).removeListener(this);
    }

    @Override
    public void onDataChanged(DataEventBuffer dataEvents) {
        for(DataEvent event : dataEvents) {
            if(event.getType() == DataEvent.TYPE_CHANGED) {
                //DataItem Changed
                DataItem item = event.getDataItem();
                if (item.getUri().getPath().compareTo(DATA_PATH) == 0) {
                    DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap();
                    updateCount(dataMap.getInt(DATA_KEY));
                }
            }
            else if(event.getType() == DataEvent.TYPE_DELETED) {
                //DataItem deleted
            }
        }
    }

    private void updateCount(int c) {
        TextView tv = findViewById(R.id.tvReceive);
        tv.setText(Integer.toString(c));
    }

//    @Override
    public void onConnected(Bundle bundle) {
//        super.onConnected();
        TextView tv = findViewById(R.id.tvStatus);
        tv.setText("Connected!");
    }

//    @Override
    public void onConnectionFailed(Bundle bundle) {
//        super.onConnectionFailed();
        TextView tv = findViewById(R.id.tvStatus);
        tv.setText("Connection Failed");
    }

}

package com.websarva.wings.android.wearbygoogle2;

import android.os.Bundle;
import android.support.wearable.activity.WearableActivity;
import android.view.View;
import android.widget.TextView;

import com.google.android.gms.wearable.DataClient;
import com.google.android.gms.wearable.DataEvent;
import com.google.android.gms.wearable.DataEventBuffer;
import com.google.android.gms.wearable.DataItem;
import com.google.android.gms.wearable.DataMap;
import com.google.android.gms.wearable.DataMapItem;
import com.google.android.gms.wearable.Wearable;

public class MainActivity extends WearableActivity implements DataClient.OnDataChangedListener {

    private TextView mTextView;
    private static final String KEY = "data";
    private static final String PATH = "/data";
    private int count = 0;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        mTextView = (TextView) findViewById(R.id.text);
        mTextView.setText(Integer.toString(0));
        // Enables Always-on
        setAmbientEnabled();
    }

    @Override
    protected void onResume() {
        super.onResume();
        Wearable.getDataClient(this).addListener(this);
    }

    @Override
    protected void onPause() {
        super.onPause();
        Wearable.getDataClient(this).removeListener(this);
    }

    @Override
    public void onDataChanged(DataEventBuffer dataEvents) {
        for(DataEvent event : dataEvents) {
            if(event.getType() == DataEvent.TYPE_CHANGED) {
                //DataItem Changed
                DataItem item = event.getDataItem();
                if (item.getUri().getPath().compareTo(PATH) == 0) {
                    DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap();
                    updateCount(dataMap.getInt(KEY));
                }
            }
            else if(event.getType() == DataEvent.TYPE_DELETED) {
                //DataItem deleted
            }
        }
    }

    private void updateCount(int c) {
        mTextView.setText(Integer.toString(c));
    }

}

試したこと

スマートフォン側のソースコードの通り、スマホでdata layer?に書き込んで、スマホがdata layerに変更があった場合、それを表示するところまではうまく動作しました
つまり、スマホからスマートウォッチへのデータの送信？がうまくいっていないものと思われます

また、スマートフォン側のソースコードで、コメントアウトしているtry-catch文を、戻して実行すると、コメントアウトされた行が実行された時点でアプリが強制終了します。

備考

C言語はかなり詳しいことまで知っていますが、Javaはクラスとメソッドなど簡単なモノしか知りません。
期限の関係でJavaを理解する時間がないので、基本的にはサンプルコードを組み合わせてしていきます。
なので、基本的なことを勉強してから来い!というお言葉はもっともなのですが、現状それができないので、そのようなお言葉は遠慮していただけるとありがたいです。

Answer 1

この質問をした翌日に同じプログラムを試してみたら正常に動作しました
何が悪かったのかは全く分かりませんが...